-/*@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*/
// 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<IEntityBase> entities(DefaultContext context, ResultSetIterImpl iter, boolean isChunked) throws SQLException {
+ protected List<IEntityBase> entities(DefaultContext context, ResultSetIterImpl iter, boolean isChunked)
+ throws SQLException {
List<IEntityBase> result = null;
JobParametersIter iterator = (JobParametersIter) iter;
while (iterator.next()) {
entity.setId(iterator.id());
entity.setData(iterator.data());
if (result == null)
- result = new ArrayList<IEntityBase>();
+ result = new ArrayList<IEntityBase>();
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");
- }
}