From: Sweidan Omar Date: Mon, 24 Jan 2022 13:52:35 +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=ed2b64a970f74c17507a20a5d9c11ed2d7fd378c;p=mediacube.git git-tfs-id: [tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32881 --- diff --git a/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobDAO.java b/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobDAO.java index 7a194b10..c775e775 100644 --- a/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobDAO.java +++ b/server/user.jobengine.osgi.db/generated/user/jobengine/db/JobDAO.java @@ -1,31 +1,30 @@ -/*@lineinfo:filename=JobDAO*//*@lineinfo:user-code*//*@lineinfo:1^1*/package user.jobengine.db; +/*@lineinfo:filename=JobDAO*//*@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.sql.SQLException; +import java.sql.Timestamp; import java.util.ArrayList; -import java.io.ByteArrayOutputStream; -import java.io.ObjectOutputStream; +import java.util.List; +import sqlj.runtime.ref.DefaultContext; +import sqlj.runtime.ref.ResultSetIterImpl; +import user.commons.IEntityBase; +import user.commons.Job; +import user.commons.JobStatus; @SuppressWarnings("unused") class JobDAO extends EntityBaseDAO { private ItemManager manager; - + public JobDAO(ItemManager manager) { super(manager); this.manager = 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; JobIter iterator = (JobIter) iter; while (iterator.next()) { @@ -34,8 +33,8 @@ class JobDAO extends EntityBaseDAO { entity.setName(iterator.name()); entity.setOwner(iterator.owner()); entity.setPriority(iterator.priority()); - entity.setProgress(iterator.progress()); - entity.setStatus(JobStatus.valueOf(iterator.status())); + entity.setProgress(iterator.progress()); + entity.setStatus(JobStatus.valueOf(iterator.status())); entity.setDescription(iterator.description()); entity.setSubmitted(iterator.submitted()); entity.setFinished(iterator.finished()); @@ -43,219 +42,218 @@ class JobDAO extends EntityBaseDAO { entity.setScheduledTime(iterator.scheduledTime()); entity.setRelated(iterator.related()); if (result == null) - result = new ArrayList(); + result = new ArrayList(); result.add(entity); - } + } iterator.close(); return result; } - + @Override public List entities(DefaultContext context, ResultSet rs) throws SQLException { JobIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:56^2*/ + /* @lineinfo:generated-code *//* @lineinfo:56^2 */ // ************************************************************ // #sql [context] iter = { CAST :rs }; // ************************************************************ -{ - 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, JobDAO_SJProfileKeys.getKey(0), 0); - try - { - __sJT_stmt.setObject(2, rs); - __sJT_execCtx.executeUpdate(); - iter = ((JobIter)(__sJT_stmt.getObject(1, JobIter.class))); - } - 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, + JobDAO_SJProfileKeys.getKey(0), 0); + try { + __sJT_stmt.setObject(2, rs); + __sJT_execCtx.executeUpdate(); + iter = ((JobIter) (__sJT_stmt.getObject(1, JobIter.class))); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:56^35*/ + /* @lineinfo:user-code *//* @lineinfo:56^35 */ return entities(context, iter, false); } - + @Override - protected ResultSetIterImpl selectByKey(DefaultContext context, long id) throws SQLException{ + protected ResultSetIterImpl selectByKey(DefaultContext context, long id) throws SQLException { JobIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:63^2*/ + /* @lineinfo:generated-code *//* @lineinfo:63^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, NAME, OWNER, PRIORITY, PROGRESS, STATUS, DESCRIPTION, SUBMITTED, FINISHED, TEMPLATE, SCHEDULEDTIME, RELATED FROM JOB 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, JobDAO_SJProfileKeys.getKey(0), 1); - try - { - __sJT_stmt.setLong(1, id); - iter = new JobIter(__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, + JobDAO_SJProfileKeys.getKey(0), 1); + try { + __sJT_stmt.setLong(1, id); + iter = new JobIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:63^169*/ + /* @lineinfo:user-code *//* @lineinfo:63^169 */ return iter; } @Override - protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException{ + protected ResultSetIterImpl selectAll(DefaultContext context) throws SQLException { JobIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:70^2*/ + /* @lineinfo:generated-code *//* @lineinfo:70^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, NAME, OWNER, PRIORITY, PROGRESS, STATUS, DESCRIPTION, SUBMITTED, FINISHED, TEMPLATE, SCHEDULEDTIME, RELATED FROM JOB }; // ************************************************************ -{ - 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, JobDAO_SJProfileKeys.getKey(0), 2); - try - { - iter = new JobIter(__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, + JobDAO_SJProfileKeys.getKey(0), 2); + try { + iter = new JobIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:70^154*/ + /* @lineinfo:user-code *//* @lineinfo:70^154 */ return iter; } - public ResultSetIterImpl selectByRelated(DefaultContext context, String related) throws SQLException{ + public ResultSetIterImpl selectByRelated(DefaultContext context, String related) throws SQLException { JobIter iter = null; - /*@lineinfo:generated-code*//*@lineinfo:76^2*/ + /* @lineinfo:generated-code *//* @lineinfo:76^2 */ // ************************************************************ // #sql [context] iter = { SELECT ID, NAME, OWNER, PRIORITY, PROGRESS, STATUS, DESCRIPTION, SUBMITTED, FINISHED, TEMPLATE, SCHEDULEDTIME, RELATED FROM JOB WHERE LOOKUP(RELATED, :related) > 0 }; // ************************************************************ -{ - 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, JobDAO_SJProfileKeys.getKey(0), 3); - try - { - __sJT_stmt.setString(1, related); - iter = new JobIter(__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, + JobDAO_SJProfileKeys.getKey(0), 3); + try { + __sJT_stmt.setString(1, related); + iter = new JobIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:76^190*/ + /* @lineinfo:user-code *//* @lineinfo:76^190 */ return iter; } - + @Override - protected void delete(DefaultContext context, long id) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:82^2*/ + protected void delete(DefaultContext context, long id) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:82^2 */ // ************************************************************ // #sql [context] { DELETE FROM JOB 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, JobDAO_SJProfileKeys.getKey(0), 4); - 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, + JobDAO_SJProfileKeys.getKey(0), 4); + try { + __sJT_stmt.setLong(1, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:82^50*/ + /* @lineinfo:user-code *//* @lineinfo:82^50 */ } - + @Override - protected void truncateTable(DefaultContext context) throws SQLException{ - /*@lineinfo:generated-code*//*@lineinfo:87^2*/ + protected void truncateTable(DefaultContext context) throws SQLException { + /* @lineinfo:generated-code */ + /* @lineinfo:87^2 */ // ************************************************************ // #sql [context] { TRUNCATE TABLE JOB 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, JobDAO_SJProfileKeys.getKey(0), 5); - 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, + JobDAO_SJProfileKeys.getKey(0), 5); + try { + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:87^84*/ + /* @lineinfo:user-code *//* @lineinfo:87^84 */ } - + @Override - protected void update(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void update(DefaultContext context, IEntityBase entity) throws SQLException { Job obj = (Job) entity; long id = obj.getId(); String name = obj.getName(); @@ -269,51 +267,50 @@ class JobDAO extends EntityBaseDAO { String template = obj.getTemplate(); Timestamp scheduledTime = obj.getScheduledTime(); String related = obj.getRelated(); - - /*@lineinfo:generated-code*//*@lineinfo:106^2*/ + + /* @lineinfo:generated-code *//* @lineinfo:106^2 */ // ************************************************************ // #sql [context] { UPDATE JOB SET NAME = :name, OWNER = :owner, PRIORITY = :priority, PROGRESS = :progress, STATUS = :status, DESCRIPTION = :description, SUBMITTED = :submitted, FINISHED = :finished, TEMPLATE = :template, SCHEDULEDTIME = :scheduledTime, RELATED = :related 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, JobDAO_SJProfileKeys.getKey(0), 6); - try - { - __sJT_stmt.setString(1, name); - __sJT_stmt.setString(2, owner); - __sJT_stmt.setInt(3, priority); - __sJT_stmt.setInt(4, progress); - __sJT_stmt.setString(5, status); - __sJT_stmt.setString(6, description); - __sJT_stmt.setTimestamp(7, submitted); - __sJT_stmt.setTimestamp(8, finished); - __sJT_stmt.setString(9, template); - __sJT_stmt.setTimestamp(10, scheduledTime); - __sJT_stmt.setString(11, related); - __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, + JobDAO_SJProfileKeys.getKey(0), 6); + try { + __sJT_stmt.setString(1, name); + __sJT_stmt.setString(2, owner); + __sJT_stmt.setInt(3, priority); + __sJT_stmt.setInt(4, progress); + __sJT_stmt.setString(5, status); + __sJT_stmt.setString(6, description); + __sJT_stmt.setTimestamp(7, submitted); + __sJT_stmt.setTimestamp(8, finished); + __sJT_stmt.setString(9, template); + __sJT_stmt.setTimestamp(10, scheduledTime); + __sJT_stmt.setString(11, related); + __sJT_stmt.setLong(12, id); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:106^288*/ + /* @lineinfo:user-code *//* @lineinfo:106^288 */ } - + @Override - protected void insert(DefaultContext context, IEntityBase entity) throws SQLException{ + protected void insert(DefaultContext context, IEntityBase entity) throws SQLException { Job obj = (Job) entity; String name = obj.getName(); String owner = obj.getOwner(); @@ -324,89 +321,88 @@ class JobDAO extends EntityBaseDAO { Timestamp submitted = obj.getSubmitted(); Timestamp finished = obj.getFinished(); String template = obj.getTemplate(); - Timestamp scheduledTime = obj.getScheduledTime(); + Timestamp scheduledTime = obj.getScheduledTime(); String related = obj.getRelated(); - /*@lineinfo:generated-code*//*@lineinfo:124^2*/ + /* @lineinfo:generated-code *//* @lineinfo:124^2 */ // ************************************************************ // #sql [context] { INSERT INTO JOB (NAME, OWNER, PRIORITY, PROGRESS, STATUS, DESCRIPTION, SUBMITTED, FINISHED, TEMPLATE, SCHEDULEDTIME, RELATED) // VALUES (:name, :owner, :priority, :progress, :status, :description, :submitted, :finished, :template, :scheduledTime, :related) }; // ************************************************************ -{ - 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, JobDAO_SJProfileKeys.getKey(0), 7); - try - { - __sJT_stmt.setString(1, name); - __sJT_stmt.setString(2, owner); - __sJT_stmt.setInt(3, priority); - __sJT_stmt.setInt(4, progress); - __sJT_stmt.setString(5, status); - __sJT_stmt.setString(6, description); - __sJT_stmt.setTimestamp(7, submitted); - __sJT_stmt.setTimestamp(8, finished); - __sJT_stmt.setString(9, template); - __sJT_stmt.setTimestamp(10, scheduledTime); - __sJT_stmt.setString(11, related); - __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, + JobDAO_SJProfileKeys.getKey(0), 7); + try { + __sJT_stmt.setString(1, name); + __sJT_stmt.setString(2, owner); + __sJT_stmt.setInt(3, priority); + __sJT_stmt.setInt(4, progress); + __sJT_stmt.setString(5, status); + __sJT_stmt.setString(6, description); + __sJT_stmt.setTimestamp(7, submitted); + __sJT_stmt.setTimestamp(8, finished); + __sJT_stmt.setString(9, template); + __sJT_stmt.setTimestamp(10, scheduledTime); + __sJT_stmt.setString(11, related); + __sJT_execCtx.executeUpdate(); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:125^130*/ - } - + /* @lineinfo:user-code *//* @lineinfo:125^130 */ + } + public List getAllIncomplete(String template) { manager.traceIn(); List result = null; DefaultContext context = manager.getDbContext(); try { JobIter iter = null; - //ResultSetIterImpl iter = null; - /*@lineinfo:generated-code*//*@lineinfo:135^3*/ + // ResultSetIterImpl iter = null; + /* @lineinfo:generated-code *//* @lineinfo:135^3 */ // ************************************************************ // #sql [context] iter = { SELECT ID, NAME, OWNER, PRIORITY, PROGRESS, STATUS, DESCRIPTION, SUBMITTED, FINISHED, TEMPLATE, SCHEDULEDTIME, RELATED // FROM JOB WHERE TEMPLATE = :template -// AND STATUS IN ('EXECUTING', 'WAIT_EXECUTOR', 'WAIT_SUSPEND', 'RUNABLE') }; +// AND STATUS IN ('EXECUTING', 'WAIT_EXECUTOR', 'WAIT_SUSPEND', 'RUNNABLE') }; // ************************************************************ -{ - 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, JobDAO_SJProfileKeys.getKey(0), 8); - try - { - __sJT_stmt.setString(1, template); - iter = new JobIter(__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, + JobDAO_SJProfileKeys.getKey(0), 8); + try { + __sJT_stmt.setString(1, template); + iter = new JobIter(__sJT_execCtx.executeQuery(), __sJT_execCtx.getFetchSize(), + __sJT_execCtx.getMaxRows()); + } finally { + __sJT_execCtx.releaseStatement(); + } + } + } // ************************************************************ -/*@lineinfo:user-code*//*@lineinfo:137^80*/ + /* @lineinfo:user-code *//* @lineinfo:137^80 */ result = getList(context, iter, false); } catch (Exception e) { throw new ItemManagerException(e); @@ -415,27 +411,26 @@ class JobDAO extends EntityBaseDAO { } manager.traceOut(); return result; - } -}/*@lineinfo:generated-code*/class JobDAO_SJProfileKeys -{ - private java.lang.Object[] keys; - private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime().getLoaderForClass(getClass()); - private static JobDAO_SJProfileKeys inst = null; - public static java.lang.Object getKey(int keyNum) - throws java.sql.SQLException - { - synchronized(user.jobengine.db.JobDAO_SJProfileKeys.class) { - if (inst == null) - { - inst = new JobDAO_SJProfileKeys(); - } - } - return inst.keys[keyNum]; - } - private JobDAO_SJProfileKeys() - throws java.sql.SQLException - { - keys = new java.lang.Object[1]; - keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.JobDAO_SJProfile0"); - } + } +} + +/* @lineinfo:generated-code */class JobDAO_SJProfileKeys { + private java.lang.Object[] keys; + private final sqlj.runtime.profile.Loader loader = sqlj.runtime.RuntimeContext.getRuntime() + .getLoaderForClass(getClass()); + private static JobDAO_SJProfileKeys inst = null; + + public static java.lang.Object getKey(int keyNum) throws java.sql.SQLException { + synchronized (user.jobengine.db.JobDAO_SJProfileKeys.class) { + if (inst == null) { + inst = new JobDAO_SJProfileKeys(); + } + } + return inst.keys[keyNum]; + } + + private JobDAO_SJProfileKeys() throws java.sql.SQLException { + keys = new java.lang.Object[1]; + keys[0] = DefaultContext.getProfileKey(loader, "user.jobengine.db.JobDAO_SJProfile0"); + } }