From: Sweidan Omar Date: Mon, 6 Dec 2021 11:16:33 +0000 (+0000) Subject: git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube... X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=896eda0a11fbfa9133e22a519be3256ce8780cf8;p=mediacube.git git-tfs-id: [tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32448 --- diff --git a/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobParametersDAO.java b/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobParametersDAO.java index c651dd94..d0c48050 100644 --- a/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobParametersDAO.java +++ b/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobParametersDAO.java @@ -1,16 +1,13 @@ -/*@lineinfo:filename=JobParametersDAO*//*@lineinfo:user-code*//*@lineinfo:1^1*/package user.jobengine.db; +/*@lineinfo:filename=JobParametersDAO*//*@lineinfo:user-code*//*@lineinfo:1^1*/ +package user.jobengine.db; -import user.commons.IEntityBase; -import sqlj.runtime.ref.*; -import user.commons.Job; -import user.commons.JobStatus; -import java.sql.Timestamp; -import java.sql.Connection; import java.sql.SQLException; -import java.sql.Statement; -import java.sql.ResultSet; -import java.util.List; import java.util.ArrayList; +import java.util.List; + +import sqlj.runtime.ref.DefaultContext; +import sqlj.runtime.ref.ResultSetIterImpl; +import user.commons.IEntityBase; /*@lineinfo:generated-code*//*@lineinfo:15^2*/ @@ -18,52 +15,46 @@ import java.util.ArrayList; // SQLJ iterator declaration: // ************************************************************ -class JobParametersIter -extends sqlj.runtime.ref.ResultSetIterImpl -implements sqlj.runtime.NamedIterator -{ - private int dataNdx; - private int idNdx; - public JobParametersIter(sqlj.runtime.profile.RTResultSet resultSet) - throws java.sql.SQLException - { - super(resultSet); - idNdx = findColumn("id"); - dataNdx = findColumn("data"); - } - public JobParametersIter(sqlj.runtime.profile.RTResultSet resultSet, int fetchSize, int maxRows) - throws java.sql.SQLException - { - super(resultSet, fetchSize, maxRows); - idNdx = findColumn("id"); - dataNdx = findColumn("data"); - } - public long id() - throws java.sql.SQLException - { - return resultSet.getLongNoNull(idNdx); - } - public byte[] data() - throws java.sql.SQLException - { - return resultSet.getBytes(dataNdx); - } -} +class JobParametersIter extends sqlj.runtime.ref.ResultSetIterImpl implements sqlj.runtime.NamedIterator { + private int dataNdx; + private int idNdx; + + public JobParametersIter(sqlj.runtime.profile.RTResultSet resultSet) throws java.sql.SQLException { + super(resultSet); + idNdx = findColumn("id"); + dataNdx = findColumn("data"); + } + + public JobParametersIter(sqlj.runtime.profile.RTResultSet resultSet, int fetchSize, int maxRows) + throws java.sql.SQLException { + super(resultSet, fetchSize, maxRows); + idNdx = findColumn("id"); + dataNdx = findColumn("data"); + } + public long id() throws java.sql.SQLException { + return resultSet.getLongNoNull(idNdx); + } + + public byte[] data() throws java.sql.SQLException { + return resultSet.getBytes(dataNdx); + } +} // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:15^52*/ +/* @lineinfo:user-code *//* @lineinfo:15^52 */ @SuppressWarnings("unused") class JobParametersDAO extends EntityBaseDAO { - + public JobParametersDAO(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; JobParametersIter iterator = (JobParametersIter) iter; while (iterator.next()) { @@ -71,242 +62,239 @@ class JobParametersDAO extends EntityBaseDAO { entity.setId(iterator.id()); entity.setData(iterator.data()); 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 { JobParametersIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:43^2*/ + /* @lineinfo:generated-code *//* @lineinfo:43^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, DATA FROM JOBPARAMETERS 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, JobParametersDAO_SJProfileKeys.getKey(0), 0); - try - { - __sJT_stmt.setLong(1, id); - iter = new JobParametersIter(__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, + JobParametersDAO_SJProfileKeys.getKey(0), 0); + try { + __sJT_stmt.setLong(1, id); + iter = new JobParametersIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:43^76*/ + /* @lineinfo:user-code *//* @lineinfo:43^76 */ return iter; } @Override - protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException{ + protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException { JobParametersIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:50^2*/ + /* @lineinfo:generated-code *//* @lineinfo:50^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, DATA FROM JOBPARAMETERS }; // ************************************************************ -{ - 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, JobParametersDAO_SJProfileKeys.getKey(0), 1); - try - { - iter = new JobParametersIter(__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, + JobParametersDAO_SJProfileKeys.getKey(0), 1); + try { + iter = new JobParametersIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:50^61*/ + /* @lineinfo:user-code *//* @lineinfo:50^61 */ return iter; } - + @Override - protected void delete(DefaultContext context, long id) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:56^2*/ + protected void delete(DefaultContext context, long id) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:56^2 */ // ************************************************************ // #sql [context] { DELETE FROM JOBPARAMETERS 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, JobParametersDAO_SJProfileKeys.getKey(0), 2); - 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, + JobParametersDAO_SJProfileKeys.getKey(0), 2); + try { + __sJT_stmt.setLong(1, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:56^60*/ + /* @lineinfo:user-code *//* @lineinfo:56^60 */ } - + @Override - protected void truncateTable(DefaultContext context) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:61^2*/ + protected void truncateTable(DefaultContext context) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:61^2 */ // ************************************************************ // #sql [context] { TRUNCATE TABLE JOBPARAMETERS 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, JobParametersDAO_SJProfileKeys.getKey(0), 3); - 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, + JobParametersDAO_SJProfileKeys.getKey(0), 3); + try { + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:61^94*/ + /* @lineinfo:user-code *//* @lineinfo:61^94 */ } - + @Override - protected void update(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void update(DefaultContext context, IEntityBase entity) throws SQLException { JobParameters obj = (JobParameters) entity; long id = obj.getId(); byte[] data = obj.getData(); - - /*@lineinfo:generated-code*//*@lineinfo:70^2*/ + + /* @lineinfo:generated-code *//* @lineinfo:70^2 */ // ************************************************************ // #sql [context] { UPDATE JOBPARAMETERS DATA = :data 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, JobParametersDAO_SJProfileKeys.getKey(0), 4); - try - { - __sJT_stmt.setBytes(1, data); - __sJT_stmt.setLong(2, 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, + JobParametersDAO_SJProfileKeys.getKey(0), 4); + try { + __sJT_stmt.setBytes(1, data); + __sJT_stmt.setLong(2, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:70^68*/ + /* @lineinfo:user-code *//* @lineinfo:70^68 */ } - + @Override - protected void insert(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void insert(DefaultContext context, IEntityBase entity) throws SQLException { JobParameters obj = (JobParameters) entity; long id = obj.getId(); byte[] data = obj.getData(); - - /*@lineinfo:generated-code*//*@lineinfo:79^2*/ + + /* @lineinfo:generated-code *//* @lineinfo:79^2 */ // ************************************************************ // #sql [context] { INSERT INTO JOBPARAMETERS (ID, DATA) VALUES (:id, :data) }; // ************************************************************ -{ - 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, JobParametersDAO_SJProfileKeys.getKey(0), 5); - try - { - __sJT_stmt.setLong(1, id); - __sJT_stmt.setBytes(2, data); - __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, + JobParametersDAO_SJProfileKeys.getKey(0), 5); + try { + __sJT_stmt.setLong(1, id); + __sJT_stmt.setBytes(2, data); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:79^76*/ + /* @lineinfo:user-code *//* @lineinfo:79^76 */ + } +} + +/* @lineinfo:generated-code */class JobParametersDAO_SJProfileKeys { + private java.lang.Object[] keys; + private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime() + .getLoaderForClass(getClass()); + private static JobParametersDAO_SJProfileKeys inst = null; + + public static java.lang.Object getKey(int keyNum) throws java.sql.SQLException { + synchronized (user.jobengine.db.JobParametersDAO_SJProfileKeys.class) { + if (inst == null) { + inst = new JobParametersDAO_SJProfileKeys(); + } + } + return inst.keys[keyNum]; + } + + private JobParametersDAO_SJProfileKeys() throws java.sql.SQLException { + keys = new java.lang.Object[1]; + keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.JobParametersDAO_SJProfile0"); } -}/*@lineinfo:generated-code*/class JobParametersDAO_SJProfileKeys -{ - private java.lang.Object[] keys; - private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime().getLoaderForClass(getClass()); - private static JobParametersDAO_SJProfileKeys inst = null; - public static java.lang.Object getKey(int keyNum) - throws java.sql.SQLException - { - synchronized(user.jobengine.db.JobParametersDAO_SJProfileKeys.class) { - if (inst == null) - { - inst = new JobParametersDAO_SJProfileKeys(); - } - } - return inst.keys[keyNum]; - } - private JobParametersDAO_SJProfileKeys() - throws java.sql.SQLException - { - keys = new java.lang.Object[1]; - keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.JobParametersDAO_SJProfile0"); - } }