-/*@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*/
// 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<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;
StoreUriIter iterator = (StoreUriIter) iter;
while (iterator.next()) {
entity.setPortNumber(iterator.portNumber());
entity.setDelivery(ItemManagerData.toDeliveryMethod(iterator.delivery()));
entity.setProtocol(ItemManagerData.toRemoteStoreProtocol(iterator.protocol()));
-
+
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 {
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();
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();
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);
}
}
/**
- * 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");
+ }
}
https://git.useribm.hu / mediacube.git / commitdiff