*/
package fr.gouv.finances.dgfip.xemelios.batch.imports.utils;
-
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+
import fr.gouv.finances.dgfip.xemelios.data.utils.jdbc.JdbcUtils;
import fr.gouv.finances.dgfip.xemelios.data.utils.jdbc.PStmtBinder;
import fr.gouv.finances.dgfip.xemelios.data.utils.jdbc.RowMapper;
-import java.util.List;
+public class ImportVOWrapper {
-import java.sql.SQLException;
-import java.sql.PreparedStatement;
-import java.sql.Connection;
+ public static final String getSelectFieldsClause(final String table) {
+ return "" + table + ".UTI_LOGIN, " + table + ".IMPORT_ID, " + table + ".FILE_NAME, " + table + ".FILE_TYPE, " + table + ".SUBMIT_DATE, " + table + ".END_DATE, " + table + ".STATUS, " + table + ".COLLECTIVITE, " + table + ".BUDGET, " + table + ".COLLECTIVITE_LIB, " + table + ".BUDGET_LIB, "
+ + table + ".ERROR_MESSAGE";
+ }
+ public static final String getSelectFieldsClause() {
+ return "UTI_LOGIN, IMPORT_ID, FILE_NAME, FILE_TYPE, SUBMIT_DATE, END_DATE, STATUS, COLLECTIVITE, BUDGET, COLLECTIVITE_LIB, BUDGET_LIB, ERROR_MESSAGE";
+ }
+
+ public static ImportVOFull getImportVOFullBy(final Connection con, final Class clazz, final String sql, final PStmtBinder binder) throws SQLException {
+ return (ImportVOFull) JdbcUtils.queryObject(con, sql, new RowMapper.ClassRowMapper(clazz), binder);
+ }
+
+ public static List getAllImportVOFullBy(final Connection con, final Class clazz, final String sql, final PStmtBinder binder) throws SQLException {
+ return JdbcUtils.queryObjects(con, sql, new RowMapper.ClassRowMapper(clazz), binder);
+ }
+
+ public static List getAllImportVOFullBy(final Connection con, final Class clazz, final String sql) throws SQLException {
+ return JdbcUtils.queryObjects(con, sql, new RowMapper.ClassRowMapper(clazz), null);
+ }
+
+ public static ImportVOFull getImportVOFullByPk(final Connection con, final ImportVOPK data) throws SQLException {
+ return getImportVOFullByPk(con, data, ImportVOFull.class);
+ }
+
+ public static ImportVOFull getImportVOFullByPk(final Connection con, final ImportVOPK data, final Class clazz) throws SQLException {
+ final String sql = "SELECT " + getSelectFieldsClause() + " FROM XEM_IMPORTS WHERE IMPORT_ID=?";
+ return getImportVOFullBy(con, clazz, sql, new PStmtBinder.SimplePStmtBinderBuilder().add(data.importId).toPStmtBinder());
+ }
+
+ public static void deleteImportVO(final Connection con, final ImportVOPK data) throws SQLException {
+ final String sql = "DELETE FROM XEM_IMPORTS WHERE IMPORT_ID=?";
+ JdbcUtils.executeUpdate(con, sql, new PStmtBinder.SimplePStmtBinderBuilder().add(data.importId == null ? (java.lang.String) null : data.importId).toPStmtBinder());
+ }
+
+ public static void insertImportVO(final Connection con, final ImportVOFull data) throws SQLException {
+ int colCount = 0;
+ final StringBuilder sql = new StringBuilder("INSERT INTO XEM_IMPORTS(");
+
+ if (data.isUtiLoginSet | data.isUtiLoginModified) {
+ sql.append("UTI_LOGIN,");
+ colCount++;
+ }
+
+ if (data.isImportIdSet | data.isImportIdModified) {
+ sql.append("IMPORT_ID,");
+ colCount++;
+ }
+
+ if (data.isFileNameSet | data.isFileNameModified) {
+ sql.append("FILE_NAME,");
+ colCount++;
+ }
+
+ if (data.isFileTypeSet | data.isFileTypeModified) {
+ sql.append("FILE_TYPE,");
+ colCount++;
+ }
+
+ if (data.isSubmitDateSet | data.isSubmitDateModified) {
+ sql.append("SUBMIT_DATE,");
+ colCount++;
+ }
+
+ if (data.isEndDateSet | data.isEndDateModified) {
+ sql.append("END_DATE,");
+ colCount++;
+ }
+
+ if (data.isStatusSet | data.isStatusModified) {
+ sql.append("STATUS,");
+ colCount++;
+ }
+
+ if (data.isCollectiviteSet | data.isCollectiviteModified) {
+ sql.append("COLLECTIVITE,");
+ colCount++;
+ }
+
+ if (data.isBudgetSet | data.isBudgetModified) {
+ sql.append("BUDGET,");
+ colCount++;
+ }
+
+ if (data.isCollectiviteLibSet | data.isCollectiviteLibModified) {
+ sql.append("COLLECTIVITE_LIB,");
+ colCount++;
+ }
+
+ if (data.isBudgetLibSet | data.isBudgetLibModified) {
+ sql.append("BUDGET_LIB,");
+ colCount++;
+ }
+
+ if (data.isErrorMessageSet | data.isErrorMessageModified) {
+ sql.append("ERROR_MESSAGE,");
+ colCount++;
+ }
+ if (colCount == 0) {
+ throw new SQLException("No data to insert");
+ }
+ sql.deleteCharAt(sql.length() - 1);
+ sql.append(") VALUES (");
+ for (int i = 0; i < colCount; i++) {
+ sql.append("?,");
+ }
+ sql.deleteCharAt(sql.length() - 1);
+ sql.append(")");
+ PStmtBinder.SimplePStmtBinderBuilder builder = new PStmtBinder.SimplePStmtBinderBuilder();
+
+ if (data.isUtiLoginSet | data.isUtiLoginModified) {
+ if (data.utiLogin == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.utiLogin);
+ }
+ }
+
+ if (data.isImportIdSet | data.isImportIdModified) {
+ if (data.importId == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.importId);
+ }
+ }
+
+ if (data.isFileNameSet | data.isFileNameModified) {
+ if (data.fileName == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.fileName);
+ }
+ }
+
+ if (data.isFileTypeSet | data.isFileTypeModified) {
+ if (data.fileType == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.fileType);
+ }
+ }
+
+ if (data.isSubmitDateSet | data.isSubmitDateModified) {
+ if (data.submitDate == null) {
+ builder = builder.add((java.sql.Timestamp) null);
+ } else {
+ builder = builder.add(data.submitDate);
+ }
+ }
+
+ if (data.isEndDateSet | data.isEndDateModified) {
+ if (data.endDate == null) {
+ builder = builder.add((java.sql.Timestamp) null);
+ } else {
+ builder = builder.add(data.endDate);
+ }
+ }
+
+ if (data.isStatusSet | data.isStatusModified) {
+ if (data.status == null) {
+ builder = builder.add((java.lang.Integer) null);
+ } else {
+ builder = builder.add(data.status);
+ }
+ }
+
+ if (data.isCollectiviteSet | data.isCollectiviteModified) {
+ if (data.collectivite == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.collectivite);
+ }
+ }
+
+ if (data.isBudgetSet | data.isBudgetModified) {
+ if (data.budget == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.budget);
+ }
+ }
+
+ if (data.isCollectiviteLibSet | data.isCollectiviteLibModified) {
+ if (data.collectiviteLib == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.collectiviteLib);
+ }
+ }
+
+ if (data.isBudgetLibSet | data.isBudgetLibModified) {
+ if (data.budgetLib == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.budgetLib);
+ }
+ }
+
+ if (data.isErrorMessageSet | data.isErrorMessageModified) {
+ if (data.errorMessage == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.errorMessage);
+ }
+ }
+
+ JdbcUtils.executeUpdate(con, sql.toString(), builder.toPStmtBinder());
+ }
+
+ public static void updateImportVO(final Connection con, final ImportVOFull data) throws SQLException {
+ final PreparedStatement ps = null;
+ final StringBuilder sql = new StringBuilder("UPDATE XEM_IMPORTS SET ");
+ if (data.isUtiLoginModified) {
+ sql.append("UTI_LOGIN=?,");
+ }
+ if (data.isFileNameModified) {
+ sql.append("FILE_NAME=?,");
+ }
+ if (data.isFileTypeModified) {
+ sql.append("FILE_TYPE=?,");
+ }
+ if (data.isSubmitDateModified) {
+ sql.append("SUBMIT_DATE=?,");
+ }
+ if (data.isEndDateModified) {
+ sql.append("END_DATE=?,");
+ }
+ if (data.isStatusModified) {
+ sql.append("STATUS=?,");
+ }
+ if (data.isCollectiviteModified) {
+ sql.append("COLLECTIVITE=?,");
+ }
+ if (data.isBudgetModified) {
+ sql.append("BUDGET=?,");
+ }
+ if (data.isCollectiviteLibModified) {
+ sql.append("COLLECTIVITE_LIB=?,");
+ }
+ if (data.isBudgetLibModified) {
+ sql.append("BUDGET_LIB=?,");
+ }
+ if (data.isErrorMessageModified) {
+ sql.append("ERROR_MESSAGE=?,");
+ }
+
+ sql.deleteCharAt(sql.length() - 1);
+ sql.append(" WHERE IMPORT_ID=?");
+ PStmtBinder.SimplePStmtBinderBuilder builder = new PStmtBinder.SimplePStmtBinderBuilder();
+
+ if (data.isUtiLoginModified) {
+ if (data.utiLogin == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.utiLogin);
+ }
+ }
+ if (data.isFileNameModified) {
+ if (data.fileName == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.fileName);
+ }
+ }
+ if (data.isFileTypeModified) {
+ if (data.fileType == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.fileType);
+ }
+ }
+ if (data.isSubmitDateModified) {
+ if (data.submitDate == null) {
+ builder = builder.add((java.sql.Timestamp) null);
+ } else {
+ builder = builder.add(data.submitDate);
+ }
+ }
+ if (data.isEndDateModified) {
+ if (data.endDate == null) {
+ builder = builder.add((java.sql.Timestamp) null);
+ } else {
+ builder = builder.add(data.endDate);
+ }
+ }
+ if (data.isStatusModified) {
+ if (data.status == null) {
+ builder = builder.add((java.lang.Integer) null);
+ } else {
+ builder = builder.add(data.status);
+ }
+ }
+ if (data.isCollectiviteModified) {
+ if (data.collectivite == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.collectivite);
+ }
+ }
+ if (data.isBudgetModified) {
+ if (data.budget == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.budget);
+ }
+ }
+ if (data.isCollectiviteLibModified) {
+ if (data.collectiviteLib == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.collectiviteLib);
+ }
+ }
+ if (data.isBudgetLibModified) {
+ if (data.budgetLib == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.budgetLib);
+ }
+ }
+ if (data.isErrorMessageModified) {
+ if (data.errorMessage == null) {
+ builder = builder.add((java.lang.String) null);
+ } else {
+ builder = builder.add(data.errorMessage);
+ }
+ }
+ builder = builder.add(data.importId);
+
+ JdbcUtils.executeUpdate(con, sql.toString(), builder.toPStmtBinder());
+ }
-public class ImportVOWrapper {
-
- public static final String getSelectFieldsClause(String table) {
- return ""+table+".UTI_LOGIN, "+table+".IMPORT_ID, "+table+".FILE_NAME, "+table+".FILE_TYPE, "+table+".SUBMIT_DATE, "+table+".END_DATE, "+table+".STATUS, "+table+".COLLECTIVITE, "+table+".BUDGET, "+table+".COLLECTIVITE_LIB, "+table+".BUDGET_LIB, "+table+".ERROR_MESSAGE";
- }
-
- public static final String getSelectFieldsClause() {
- return "UTI_LOGIN, IMPORT_ID, FILE_NAME, FILE_TYPE, SUBMIT_DATE, END_DATE, STATUS, COLLECTIVITE, BUDGET, COLLECTIVITE_LIB, BUDGET_LIB, ERROR_MESSAGE";
- }
-
- public static ImportVOFull getImportVOFullBy(Connection con, Class clazz, String sql, PStmtBinder binder) throws SQLException {
- return (ImportVOFull)JdbcUtils.queryObject(con, sql, new RowMapper.ClassRowMapper(clazz), binder);
- }
-
- public static List getAllImportVOFullBy(Connection con, Class clazz, String sql, PStmtBinder binder) throws SQLException {
- return JdbcUtils.queryObjects(con, sql, new RowMapper.ClassRowMapper(clazz), binder);
- }
-
- public static List getAllImportVOFullBy(Connection con, Class clazz, String sql) throws SQLException {
- return JdbcUtils.queryObjects(con, sql, new RowMapper.ClassRowMapper(clazz), null);
- }
-
- public static ImportVOFull getImportVOFullByPk(Connection con, ImportVOPK data) throws SQLException {
- return getImportVOFullByPk(con, data, ImportVOFull.class);
- }
-
- public static ImportVOFull getImportVOFullByPk(Connection con, ImportVOPK data, Class clazz) throws SQLException {
- String sql = "SELECT " + getSelectFieldsClause() + " FROM XEM_IMPORTS WHERE IMPORT_ID=?";
- return getImportVOFullBy(con, clazz, sql, new PStmtBinder.SimplePStmtBinderBuilder().add(data.importId).toPStmtBinder());
- }
-
- public static void deleteImportVO(Connection con, ImportVOPK data) throws SQLException {
- String sql = "DELETE FROM XEM_IMPORTS WHERE IMPORT_ID=?";
- JdbcUtils.executeUpdate(con,sql,new PStmtBinder.SimplePStmtBinderBuilder().add(data.importId==null ? (java.lang.String)null : data.importId).toPStmtBinder());
- }
-
-
- public static void insertImportVO(Connection con, ImportVOFull data) throws SQLException {
- int colCount=0;
- StringBuilder sql = new StringBuilder("INSERT INTO XEM_IMPORTS(");
-
-
- if(data.isUtiLoginSet | data.isUtiLoginModified) {
- sql.append("UTI_LOGIN,");
- colCount++;
- }
-
- if(data.isImportIdSet | data.isImportIdModified) {
- sql.append("IMPORT_ID,");
- colCount++;
- }
-
- if(data.isFileNameSet | data.isFileNameModified) {
- sql.append("FILE_NAME,");
- colCount++;
- }
-
- if(data.isFileTypeSet | data.isFileTypeModified) {
- sql.append("FILE_TYPE,");
- colCount++;
- }
-
- if(data.isSubmitDateSet | data.isSubmitDateModified) {
- sql.append("SUBMIT_DATE,");
- colCount++;
- }
-
- if(data.isEndDateSet | data.isEndDateModified) {
- sql.append("END_DATE,");
- colCount++;
- }
-
- if(data.isStatusSet | data.isStatusModified) {
- sql.append("STATUS,");
- colCount++;
- }
-
- if(data.isCollectiviteSet | data.isCollectiviteModified) {
- sql.append("COLLECTIVITE,");
- colCount++;
- }
-
- if(data.isBudgetSet | data.isBudgetModified) {
- sql.append("BUDGET,");
- colCount++;
- }
-
- if(data.isCollectiviteLibSet | data.isCollectiviteLibModified) {
- sql.append("COLLECTIVITE_LIB,");
- colCount++;
- }
-
- if(data.isBudgetLibSet | data.isBudgetLibModified) {
- sql.append("BUDGET_LIB,");
- colCount++;
- }
-
- if(data.isErrorMessageSet | data.isErrorMessageModified) {
- sql.append("ERROR_MESSAGE,");
- colCount++;
- }
- if(colCount==0) throw new SQLException("No data to insert");
- sql.deleteCharAt(sql.length() - 1);
- sql.append(") VALUES (");
- for(int i=0;i<colCount;i++) sql.append("?,");
- sql.deleteCharAt(sql.length() - 1);
- sql.append(")");
- PStmtBinder.SimplePStmtBinderBuilder builder = new PStmtBinder.SimplePStmtBinderBuilder();
-
- if(data.isUtiLoginSet | data.isUtiLoginModified) {
- if(data.utiLogin==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.utiLogin);
- }
-
- if(data.isImportIdSet | data.isImportIdModified) {
- if(data.importId==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.importId);
- }
-
- if(data.isFileNameSet | data.isFileNameModified) {
- if(data.fileName==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.fileName);
- }
-
- if(data.isFileTypeSet | data.isFileTypeModified) {
- if(data.fileType==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.fileType);
- }
-
- if(data.isSubmitDateSet | data.isSubmitDateModified) {
- if(data.submitDate==null) builder=builder.add((java.sql.Timestamp)null); else builder=builder.add(data.submitDate);
- }
-
- if(data.isEndDateSet | data.isEndDateModified) {
- if(data.endDate==null) builder=builder.add((java.sql.Timestamp)null); else builder=builder.add(data.endDate);
- }
-
- if(data.isStatusSet | data.isStatusModified) {
- if(data.status==null) builder=builder.add((java.lang.Integer)null); else builder=builder.add(data.status);
- }
-
- if(data.isCollectiviteSet | data.isCollectiviteModified) {
- if(data.collectivite==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.collectivite);
- }
-
- if(data.isBudgetSet | data.isBudgetModified) {
- if(data.budget==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.budget);
- }
-
- if(data.isCollectiviteLibSet | data.isCollectiviteLibModified) {
- if(data.collectiviteLib==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.collectiviteLib);
- }
-
- if(data.isBudgetLibSet | data.isBudgetLibModified) {
- if(data.budgetLib==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.budgetLib);
- }
-
- if(data.isErrorMessageSet | data.isErrorMessageModified) {
- if(data.errorMessage==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.errorMessage);
- }
-
- JdbcUtils.executeUpdate(con,sql.toString(),builder.toPStmtBinder());
- }
-
- public static void updateImportVO(Connection con, ImportVOFull data) throws SQLException {
- PreparedStatement ps = null;
- StringBuilder sql=new StringBuilder("UPDATE XEM_IMPORTS SET ");
- if(data.isUtiLoginModified) sql.append("UTI_LOGIN=?,");
- if(data.isFileNameModified) sql.append("FILE_NAME=?,");
- if(data.isFileTypeModified) sql.append("FILE_TYPE=?,");
- if(data.isSubmitDateModified) sql.append("SUBMIT_DATE=?,");
- if(data.isEndDateModified) sql.append("END_DATE=?,");
- if(data.isStatusModified) sql.append("STATUS=?,");
- if(data.isCollectiviteModified) sql.append("COLLECTIVITE=?,");
- if(data.isBudgetModified) sql.append("BUDGET=?,");
- if(data.isCollectiviteLibModified) sql.append("COLLECTIVITE_LIB=?,");
- if(data.isBudgetLibModified) sql.append("BUDGET_LIB=?,");
- if(data.isErrorMessageModified) sql.append("ERROR_MESSAGE=?,");
-
- sql.deleteCharAt(sql.length()-1);
- sql.append(" WHERE IMPORT_ID=?");
- PStmtBinder.SimplePStmtBinderBuilder builder = new PStmtBinder.SimplePStmtBinderBuilder();
-
- if(data.isUtiLoginModified) {
- if(data.utiLogin==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.utiLogin);
- }
- if(data.isFileNameModified) {
- if(data.fileName==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.fileName);
- }
- if(data.isFileTypeModified) {
- if(data.fileType==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.fileType);
- }
- if(data.isSubmitDateModified) {
- if(data.submitDate==null) builder=builder.add((java.sql.Timestamp)null); else builder=builder.add(data.submitDate);
- }
- if(data.isEndDateModified) {
- if(data.endDate==null) builder=builder.add((java.sql.Timestamp)null); else builder=builder.add(data.endDate);
- }
- if(data.isStatusModified) {
- if(data.status==null) builder=builder.add((java.lang.Integer)null); else builder=builder.add(data.status);
- }
- if(data.isCollectiviteModified) {
- if(data.collectivite==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.collectivite);
- }
- if(data.isBudgetModified) {
- if(data.budget==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.budget);
- }
- if(data.isCollectiviteLibModified) {
- if(data.collectiviteLib==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.collectiviteLib);
- }
- if(data.isBudgetLibModified) {
- if(data.budgetLib==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.budgetLib);
- }
- if(data.isErrorMessageModified) {
- if(data.errorMessage==null) builder=builder.add((java.lang.String)null); else builder=builder.add(data.errorMessage);
- }
- builder=builder.add(data.importId);
-
- JdbcUtils.executeUpdate(con,sql.toString(),builder.toPStmtBinder());
- }
-
}
-
\ No newline at end of file