-/*@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<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;
JobIter iterator = (JobIter) iter;
while (iterator.next()) {
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());
entity.setScheduledTime(iterator.scheduledTime());
entity.setRelated(iterator.related());
if (result == null)
- result = new ArrayList<IEntityBase>();
+ result = new ArrayList<IEntityBase>();
result.add(entity);
- }
+ }
iterator.close();
return result;
}
-
+
@Override
public List<IEntityBase> 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();
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();
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<IEntityBase> getAllIncomplete(String template) {
manager.traceIn();
List<IEntityBase> 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);
}
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");
+ }
}