From 4674342441a4c0c0de719ed6e8fb994399cad117 Mon Sep 17 00:00:00 2001 From: Sweidan Omar Date: Mon, 6 Dec 2021 11:18:09 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32454 --- .../user/jobengine/db/StoreUriDAO.java | 684 +++++++++--------- 1 file changed, 333 insertions(+), 351 deletions(-) diff --git a/server/user.jobengine.osgi.db/generated/user/jobengine/db/StoreUriDAO.java b/server/user.jobengine.osgi.db/generated/user/jobengine/db/StoreUriDAO.java index ecd56f04..ad11cd78 100644 --- a/server/user.jobengine.osgi.db/generated/user/jobengine/db/StoreUriDAO.java +++ b/server/user.jobengine.osgi.db/generated/user/jobengine/db/StoreUriDAO.java @@ -1,13 +1,14 @@ -/*@lineinfo:filename=StoreUriDAO*//*@lineinfo:user-code*//*@lineinfo:1^1*/package user.jobengine.db; +/*@lineinfo:filename=StoreUriDAO*//*@lineinfo:user-code*//*@lineinfo:1^1*/ +package user.jobengine.db; -import user.commons.IEntityBase; -import sqlj.runtime.ref.*; -import user.commons.StoreUri; import java.sql.SQLException; -import java.util.List; import java.util.ArrayList; -import user.commons.remotestore.RemoteStoreProtocol; -import user.commons.remotestore.DeliveryMethod; +import java.util.List; + +import sqlj.runtime.ref.DefaultContext; +import sqlj.runtime.ref.ResultSetIterImpl; +import user.commons.IEntityBase; +import user.commons.StoreUri; /*@lineinfo:generated-code*//*@lineinfo:12^2*/ @@ -15,133 +16,117 @@ import user.commons.remotestore.DeliveryMethod; // SQLJ iterator declaration: // ************************************************************ -class StoreUriIter -extends sqlj.runtime.ref.ResultSetIterImpl -implements sqlj.runtime.NamedIterator -{ - private int protocolNdx; - private int deliveryNdx; - private int portNumberNdx; - private int rootPathNdx; - private int passwordNdx; - private int userNameNdx; - private int isTargetNdx; - private int isSourceNdx; - private int isStreamNdx; - private int uriNdx; - private int storeIdNdx; - private int idNdx; - public StoreUriIter(sqlj.runtime.profile.RTResultSet resultSet) - throws java.sql.SQLException - { - super(resultSet); - idNdx = findColumn("id"); - storeIdNdx = findColumn("storeId"); - uriNdx = findColumn("uri"); - isStreamNdx = findColumn("isStream"); - isSourceNdx = findColumn("isSource"); - isTargetNdx = findColumn("isTarget"); - userNameNdx = findColumn("userName"); - passwordNdx = findColumn("password"); - rootPathNdx = findColumn("rootPath"); - portNumberNdx = findColumn("portNumber"); - deliveryNdx = findColumn("delivery"); - protocolNdx = findColumn("protocol"); - } - public StoreUriIter(sqlj.runtime.profile.RTResultSet resultSet, int fetchSize, int maxRows) - throws java.sql.SQLException - { - super(resultSet, fetchSize, maxRows); - idNdx = findColumn("id"); - storeIdNdx = findColumn("storeId"); - uriNdx = findColumn("uri"); - isStreamNdx = findColumn("isStream"); - isSourceNdx = findColumn("isSource"); - isTargetNdx = findColumn("isTarget"); - userNameNdx = findColumn("userName"); - passwordNdx = findColumn("password"); - rootPathNdx = findColumn("rootPath"); - portNumberNdx = findColumn("portNumber"); - deliveryNdx = findColumn("delivery"); - protocolNdx = findColumn("protocol"); - } - public long id() - throws java.sql.SQLException - { - return resultSet.getLongNoNull(idNdx); - } - public long storeId() - throws java.sql.SQLException - { - return resultSet.getLongNoNull(storeIdNdx); - } - public String uri() - throws java.sql.SQLException - { - return resultSet.getString(uriNdx); - } - public String isStream() - throws java.sql.SQLException - { - return resultSet.getString(isStreamNdx); - } - public String isSource() - throws java.sql.SQLException - { - return resultSet.getString(isSourceNdx); - } - public String isTarget() - throws java.sql.SQLException - { - return resultSet.getString(isTargetNdx); - } - public String userName() - throws java.sql.SQLException - { - return resultSet.getString(userNameNdx); - } - public String password() - throws java.sql.SQLException - { - return resultSet.getString(passwordNdx); - } - public String rootPath() - throws java.sql.SQLException - { - return resultSet.getString(rootPathNdx); - } - public Integer portNumber() - throws java.sql.SQLException - { - return resultSet.getIntWrapper(portNumberNdx); - } - public String delivery() - throws java.sql.SQLException - { - return resultSet.getString(deliveryNdx); - } - public String protocol() - throws java.sql.SQLException - { - return resultSet.getString(protocolNdx); - } -} +class StoreUriIter extends sqlj.runtime.ref.ResultSetIterImpl implements sqlj.runtime.NamedIterator { + private int protocolNdx; + private int deliveryNdx; + private int portNumberNdx; + private int rootPathNdx; + private int passwordNdx; + private int userNameNdx; + private int isTargetNdx; + private int isSourceNdx; + private int isStreamNdx; + private int uriNdx; + private int storeIdNdx; + private int idNdx; + + public StoreUriIter(sqlj.runtime.profile.RTResultSet resultSet) throws java.sql.SQLException { + super(resultSet); + idNdx = findColumn("id"); + storeIdNdx = findColumn("storeId"); + uriNdx = findColumn("uri"); + isStreamNdx = findColumn("isStream"); + isSourceNdx = findColumn("isSource"); + isTargetNdx = findColumn("isTarget"); + userNameNdx = findColumn("userName"); + passwordNdx = findColumn("password"); + rootPathNdx = findColumn("rootPath"); + portNumberNdx = findColumn("portNumber"); + deliveryNdx = findColumn("delivery"); + protocolNdx = findColumn("protocol"); + } + + public StoreUriIter(sqlj.runtime.profile.RTResultSet resultSet, int fetchSize, int maxRows) + throws java.sql.SQLException { + super(resultSet, fetchSize, maxRows); + idNdx = findColumn("id"); + storeIdNdx = findColumn("storeId"); + uriNdx = findColumn("uri"); + isStreamNdx = findColumn("isStream"); + isSourceNdx = findColumn("isSource"); + isTargetNdx = findColumn("isTarget"); + userNameNdx = findColumn("userName"); + passwordNdx = findColumn("password"); + rootPathNdx = findColumn("rootPath"); + portNumberNdx = findColumn("portNumber"); + deliveryNdx = findColumn("delivery"); + protocolNdx = findColumn("protocol"); + } + public long id() throws java.sql.SQLException { + return resultSet.getLongNoNull(idNdx); + } + + public long storeId() throws java.sql.SQLException { + return resultSet.getLongNoNull(storeIdNdx); + } + + public String uri() throws java.sql.SQLException { + return resultSet.getString(uriNdx); + } + + public String isStream() throws java.sql.SQLException { + return resultSet.getString(isStreamNdx); + } + + public String isSource() throws java.sql.SQLException { + return resultSet.getString(isSourceNdx); + } + + public String isTarget() throws java.sql.SQLException { + return resultSet.getString(isTargetNdx); + } + + public String userName() throws java.sql.SQLException { + return resultSet.getString(userNameNdx); + } + + public String password() throws java.sql.SQLException { + return resultSet.getString(passwordNdx); + } + + public String rootPath() throws java.sql.SQLException { + return resultSet.getString(rootPathNdx); + } + + public Integer portNumber() throws java.sql.SQLException { + return resultSet.getIntWrapper(portNumberNdx); + } + + public String delivery() throws java.sql.SQLException { + return resultSet.getString(deliveryNdx); + } + + public String protocol() throws java.sql.SQLException { + return resultSet.getString(protocolNdx); + } +} // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:12^216*/ +/* @lineinfo:user-code *//* @lineinfo:12^216 */ @SuppressWarnings("unused") class StoreUriDAO extends EntityBaseDAO { - + public StoreUriDAO(ItemManager manager) { super(manager); } - + @Override - protected List entities(DefaultContext context, ResultSetIterImpl iter, boolean isChunked) throws SQLException { + protected List entities(DefaultContext context, ResultSetIterImpl iter, boolean isChunked) + throws SQLException { List result = null; StoreUriIter iterator = (StoreUriIter) iter; while (iterator.next()) { @@ -158,186 +143,186 @@ class StoreUriDAO extends EntityBaseDAO { entity.setPortNumber(iterator.portNumber()); entity.setDelivery(ItemManagerData.toDeliveryMethod(iterator.delivery())); entity.setProtocol(ItemManagerData.toRemoteStoreProtocol(iterator.protocol())); - + if (result == null) - result = new ArrayList(); + result = new ArrayList(); result.add(entity); - } + } iterator.close(); return result; } - + @Override - protected ResultSetIterImpl selectByKey(DefaultContext context, long id) throws SQLException{ + protected ResultSetIterImpl selectByKey(DefaultContext context, long id) throws SQLException { StoreUriIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:52^2*/ + /* @lineinfo:generated-code *//* @lineinfo:52^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, STOREID, URI, ISSTREAM, ISSOURCE, ISTARGET, USERNAME, PASSWORD, ROOTPATH, PORTNUMBER, DELIVERY, PROTOCOL FROM STOREURI WHERE ID = :id }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 0); - try - { - __sJT_stmt.setLong(1, id); - iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), __sJT_execCtx.getMaxRows()); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 0); + try { + __sJT_stmt.setLong(1, id); + iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:52^171*/ + /* @lineinfo:user-code *//* @lineinfo:52^171 */ return iter; } @Override - protected ResultSetIterImpl selectByForeignKey(DefaultContext context, long id) throws SQLException{ + protected ResultSetIterImpl selectByForeignKey(DefaultContext context, long id) throws SQLException { StoreUriIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:59^2*/ + /* @lineinfo:generated-code *//* @lineinfo:59^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, STOREID, URI, ISSTREAM, ISSOURCE, ISTARGET, USERNAME, PASSWORD, ROOTPATH, PORTNUMBER, DELIVERY, PROTOCOL FROM STOREURI WHERE STOREID = :id }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 1); - try - { - __sJT_stmt.setLong(1, id); - iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), __sJT_execCtx.getMaxRows()); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 1); + try { + __sJT_stmt.setLong(1, id); + iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:59^176*/ + /* @lineinfo:user-code *//* @lineinfo:59^176 */ return iter; } @Override - protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException{ + protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException { StoreUriIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:66^2*/ + /* @lineinfo:generated-code *//* @lineinfo:66^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, STOREID, URI, ISSTREAM, ISSOURCE, ISTARGET, USERNAME, PASSWORD, ROOTPATH, PORTNUMBER, DELIVERY, PROTOCOL FROM STOREURI }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 2); - try - { - iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), __sJT_execCtx.getMaxRows()); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 2); + try { + iter = new StoreUriIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:66^156*/ + /* @lineinfo:user-code *//* @lineinfo:66^156 */ return iter; } - + @Override - protected void delete(DefaultContext context, long id) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:72^2*/ + protected void delete(DefaultContext context, long id) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:72^2 */ // ************************************************************ // #sql [context] { DELETE FROM STOREURI WHERE ID = :id }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 3); - try - { - __sJT_stmt.setLong(1, id); - __sJT_execCtx.executeUpdate(); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 3); + try { + __sJT_stmt.setLong(1, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:72^55*/ + /* @lineinfo:user-code *//* @lineinfo:72^55 */ } - + @Override - protected void truncateTable(DefaultContext context) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:77^2*/ + protected void truncateTable(DefaultContext context) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:77^2 */ // ************************************************************ // #sql [context] { TRUNCATE TABLE STOREURI DROP STORAGE IGNORE DELETE TRIGGERS IMMEDIATE }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 4); - try - { - __sJT_execCtx.executeUpdate(); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 4); + try { + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:77^89*/ + /* @lineinfo:user-code *//* @lineinfo:77^89 */ } - + @Override - protected void update(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void update(DefaultContext context, IEntityBase entity) throws SQLException { StoreUri obj = (StoreUri) entity; long id = obj.getId(); long storeId = obj.getStoreId(); @@ -351,51 +336,50 @@ class StoreUriDAO extends EntityBaseDAO { Integer portNumber = obj.getPortNumber(); String delivery = obj.getDelivery() == null ? null : obj.getDelivery().toString(); String protocol = obj.getProtocol() == null ? null : obj.getProtocol().toString(); - - /*@lineinfo:generated-code*//*@lineinfo:96^2*/ + + /* @lineinfo:generated-code *//* @lineinfo:96^2 */ // ************************************************************ // #sql [context] { UPDATE STOREURI SET STOREID = :storeId, URI = :uri, ISSTREAM = :isStream, ISSOURCE = :isSource, ISTARGET = :isTarget, USERNAME = :userName, PASSWORD = :password, ROOTPATH = :rootPath, PORTNUMBER = :portNumber, DELIVERY = :delivery, PROTOCOL = :protocol WHERE ID = :id }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 5); - try - { - __sJT_stmt.setLong(1, storeId); - __sJT_stmt.setString(2, uri); - __sJT_stmt.setString(3, isStream); - __sJT_stmt.setString(4, isSource); - __sJT_stmt.setString(5, isTarget); - __sJT_stmt.setString(6, userName); - __sJT_stmt.setString(7, password); - __sJT_stmt.setString(8, rootPath); - __sJT_stmt.setIntWrapper(9, portNumber); - __sJT_stmt.setString(10, delivery); - __sJT_stmt.setString(11, protocol); - __sJT_stmt.setLong(12, id); - __sJT_execCtx.executeUpdate(); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 5); + try { + __sJT_stmt.setLong(1, storeId); + __sJT_stmt.setString(2, uri); + __sJT_stmt.setString(3, isStream); + __sJT_stmt.setString(4, isSource); + __sJT_stmt.setString(5, isTarget); + __sJT_stmt.setString(6, userName); + __sJT_stmt.setString(7, password); + __sJT_stmt.setString(8, rootPath); + __sJT_stmt.setIntWrapper(9, portNumber); + __sJT_stmt.setString(10, delivery); + __sJT_stmt.setString(11, protocol); + __sJT_stmt.setLong(12, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:96^287*/ + /* @lineinfo:user-code *//* @lineinfo:96^287 */ } - + @Override - protected void insert(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void insert(DefaultContext context, IEntityBase entity) throws SQLException { StoreUri obj = (StoreUri) entity; long storeId = obj.getStoreId(); String uri = obj.getUri(); @@ -409,52 +393,51 @@ class StoreUriDAO extends EntityBaseDAO { String delivery = obj.getDelivery() == null ? null : obj.getDelivery().toString(); String protocol = obj.getProtocol() == null ? null : obj.getProtocol().toString(); - /*@lineinfo:generated-code*//*@lineinfo:114^2*/ + /* @lineinfo:generated-code *//* @lineinfo:114^2 */ // ************************************************************ // #sql [context] { INSERT INTO STOREURI (STOREID, URI, ISSTREAM, ISSOURCE, ISTARGET, USERNAME, PASSWORD, ROOTPATH, PORTNUMBER, DELIVERY, PROTOCOL) VALUES (:storeId, :uri, :isStream, :isSource, :isTarget, :userName, :password, :rootPath, :portNumber, :delivery, :protocol) }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 6); - try - { - __sJT_stmt.setLong(1, storeId); - __sJT_stmt.setString(2, uri); - __sJT_stmt.setString(3, isStream); - __sJT_stmt.setString(4, isSource); - __sJT_stmt.setString(5, isTarget); - __sJT_stmt.setString(6, userName); - __sJT_stmt.setString(7, password); - __sJT_stmt.setString(8, rootPath); - __sJT_stmt.setIntWrapper(9, portNumber); - __sJT_stmt.setString(10, delivery); - __sJT_stmt.setString(11, protocol); - __sJT_execCtx.executeUpdate(); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 6); + try { + __sJT_stmt.setLong(1, storeId); + __sJT_stmt.setString(2, uri); + __sJT_stmt.setString(3, isStream); + __sJT_stmt.setString(4, isSource); + __sJT_stmt.setString(5, isTarget); + __sJT_stmt.setString(6, userName); + __sJT_stmt.setString(7, password); + __sJT_stmt.setString(8, rootPath); + __sJT_stmt.setIntWrapper(9, portNumber); + __sJT_stmt.setString(10, delivery); + __sJT_stmt.setString(11, protocol); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:114^272*/ + /* @lineinfo:user-code *//* @lineinfo:114^272 */ } - + void addAll(DefaultContext context, IEntityBase entity) throws SQLException { manager.traceIn(); - Store store = (Store) entity; + Store store = (Store) entity; if (store != null && store.getStoreUris() != null) { - for (StoreUri su: store.getStoreUris()) { + for (StoreUri su : store.getStoreUris()) { su.setStoreId(store.getId()); add(context, su); } @@ -463,62 +446,61 @@ class StoreUriDAO extends EntityBaseDAO { } /** - * T\ufffdrli a param\ufffdterk\ufffdnt kapott Store azonos\ufffdt\ufffdhoz tartoz\ufffd StoreUri bejegyz\ufffdseket. + * T\ufffdrli a param\ufffdterk\ufffdnt kapott Store azonos\ufffdt\ufffdhoz + * tartoz\ufffd StoreUri bejegyz\ufffdseket. */ void removeAll(DefaultContext context, long filterId) throws SQLException { manager.traceIn(); - /*@lineinfo:generated-code*//*@lineinfo:134^2*/ + /* @lineinfo:generated-code *//* @lineinfo:134^2 */ // ************************************************************ // #sql [context] { DELETE FROM STOREURI WHERE STOREID = :filterId }; // ************************************************************ -{ - sqlj.runtime.ConnectionContext __sJT_connCtx = context; - if (__sJT_connCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); - sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); - if (__sJT_execCtx == null) sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); - synchronized (__sJT_execCtx) { - sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, StoreUriDAO_SJProfileKeys.getKey(0), 7); - try - { - __sJT_stmt.setLong(1, filterId); - __sJT_execCtx.executeUpdate(); - } - finally - { - __sJT_execCtx.releaseStatement(); - } - } -} - + { + sqlj.runtime.ConnectionContext __sJT_connCtx = context; + if (__sJT_connCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_DEFAULT_CONN_CTX(); + sqlj.runtime.ExecutionContext __sJT_execCtx = __sJT_connCtx.getExecutionContext(); + if (__sJT_execCtx == null) + sqlj.runtime.error.RuntimeRefErrors.raise_NULL_EXEC_CTX(); + synchronized (__sJT_execCtx) { + sqlj.runtime.profile.RTStatement __sJT_stmt = __sJT_execCtx.registerStatement(__sJT_connCtx, + StoreUriDAO_SJProfileKeys.getKey(0), 7); + try { + __sJT_stmt.setLong(1, filterId); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:134^66*/ + /* @lineinfo:user-code *//* @lineinfo:134^66 */ manager.traceOut(); } -}/*@lineinfo:generated-code*/class StoreUriDAO_SJProfileKeys -{ - private java.lang.Object[] keys; - private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime().getLoaderForClass(getClass()); - private static StoreUriDAO_SJProfileKeys inst = null; - public static java.lang.Object getKey(int keyNum) - throws java.sql.SQLException - { - synchronized(user.jobengine.db.StoreUriDAO_SJProfileKeys.class) { - if (inst == null) - { - inst = new StoreUriDAO_SJProfileKeys(); - } - } - return inst.keys[keyNum]; - } - private StoreUriDAO_SJProfileKeys() - throws java.sql.SQLException - { - keys = new java.lang.Object[1]; - keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.StoreUriDAO_SJProfile0"); - } +} + +/* @lineinfo:generated-code */class StoreUriDAO_SJProfileKeys { + private java.lang.Object[] keys; + private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime() + .getLoaderForClass(getClass()); + private static StoreUriDAO_SJProfileKeys inst = null; + + public static java.lang.Object getKey(int keyNum) throws java.sql.SQLException { + synchronized (user.jobengine.db.StoreUriDAO_SJProfileKeys.class) { + if (inst == null) { + inst = new StoreUriDAO_SJProfileKeys(); + } + } + return inst.keys[keyNum]; + } + + private StoreUriDAO_SJProfileKeys() throws java.sql.SQLException { + keys = new java.lang.Object[1]; + keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.StoreUriDAO_SJProfile0"); + } } -- 2.54.0