From b712fbef93821d17a7c126b56e22b0669da06837 Mon Sep 17 00:00:00 2001 From: datagear Date: Mon, 27 May 2019 20:44:03 +0800 Subject: [PATCH] =?UTF-8?q?[dataexchange]=E5=AE=8C=E5=96=84CSV=E5=AF=BC?= =?UTF-8?q?=E5=85=A5=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/datagear/dataexchange/Import.java | 20 +- .../datagear/dataexchange/ImportReporter.java | 21 ++ .../UnsupportedExportException.java | 2 +- .../AbstractTextDevotedDataImporter.java | 310 ++++++++++++++++-- .../support/AbstractTextImport.java | 20 +- .../dataexchange/support/CsvDataImporter.java | 49 ++- .../dataexchange/support/CsvImport.java | 7 +- .../support/ExceptionResolve.java | 23 ++ .../support/IllegalSourceValueException.java | 39 +++ .../support/InsertSqlException.java | 56 ++++ .../support/NoneColumnFoundException.java | 54 +++ ...SetInsertPreparedColumnValueException.java | 107 ++++++ .../support/UnsupportedSqlTypeException.java | 52 +++ 13 files changed, 719 insertions(+), 41 deletions(-) create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/ImportReporter.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/ExceptionResolve.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/IllegalSourceValueException.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/InsertSqlException.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/NoneColumnFoundException.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/SetInsertPreparedColumnValueException.java create mode 100644 datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/UnsupportedSqlTypeException.java diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/Import.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/Import.java index 608ea7fe..a4a3e776 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/Import.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/Import.java @@ -20,12 +20,15 @@ public abstract class Import /** 导入出错时是否终止 */ private boolean abortOnError; + /** 导入报告 */ + private ImportReporter importReporter; + public Import() { super(); } - public Import(Connection connection, boolean abortOnError) + public Import(Connection connection, boolean abortOnError, ImportReporter importReporter) { super(); this.connection = connection; @@ -51,4 +54,19 @@ public abstract class Import { this.abortOnError = abortOnError; } + + public boolean hasImportReporter() + { + return (this.importReporter != null); + } + + public ImportReporter getImportReporter() + { + return importReporter; + } + + public void setImportReporter(ImportReporter importReporter) + { + this.importReporter = importReporter; + } } diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/ImportReporter.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/ImportReporter.java new file mode 100644 index 00000000..72048c6c --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/ImportReporter.java @@ -0,0 +1,21 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange; + +/** + * 数据导入报告。 + * + * @author datagear@163.com + * + */ +public interface ImportReporter +{ + /** + * 报告导入异常。 + * + * @param e + */ + void report(DataImportException e); +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/UnsupportedExportException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/UnsupportedExportException.java index dc3d3cac..54f3d004 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/UnsupportedExportException.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/UnsupportedExportException.java @@ -13,7 +13,7 @@ package org.datagear.dataexchange; * @author datagear@163.com * */ -public class UnsupportedExportException extends DataImportException +public class UnsupportedExportException extends DataExportException { private static final long serialVersionUID = 1L; diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextDevotedDataImporter.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextDevotedDataImporter.java index c095a2ec..4430d4eb 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextDevotedDataImporter.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextDevotedDataImporter.java @@ -17,18 +17,22 @@ import java.sql.SQLXML; import java.sql.Timestamp; import java.sql.Types; import java.text.NumberFormat; +import java.text.ParseException; +import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import org.apache.commons.codec.DecoderException; import org.apache.commons.codec.binary.Base64; import org.apache.commons.codec.binary.Hex; -import org.datagear.dataexchange.DataImportException; import org.datagear.dataexchange.DevotedDataImporter; import org.datagear.dataexchange.Import; +import org.datagear.dataexchange.ImportReporter; import org.datagear.dataexchange.support.DataFormat.BinaryFormat; import org.datagear.dbinfo.ColumnInfo; import org.datagear.dbinfo.DatabaseInfoResolver; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * 抽象文本{@linkplain DevotedDataImporter}。 @@ -39,43 +43,189 @@ import org.datagear.dbinfo.DatabaseInfoResolver; */ public abstract class AbstractTextDevotedDataImporter extends AbstractDevotedDataImporter { + protected static final Logger LOGGER = LoggerFactory.getLogger(AbstractTextDevotedDataImporter.class); + public AbstractTextDevotedDataImporter() { super(); } /** - * 构建{@linkplain DataFormatContext}。 + * 构建{@linkplain InsertContext}。 * * @param impt + * @param table * @return */ - protected SetParameterContext buildSetParameterContext(AbstractTextImport impt) + protected InsertContext buildInsertContext(AbstractTextImport impt, String table) { - return new SetParameterContext(impt.getDataFormat()); + return new InsertContext(impt.getDataFormat(), table); + } + + /** + * 执行插入{@linkplain PreparedStatement}。 + * + * @param impt + * @param st + * @param insertContext + * @throws InsertSqlException + */ + protected void executeInsertPreparedStatement(AbstractTextImport impt, PreparedStatement st, + InsertContext insertContext) throws InsertSqlException + { + try + { + st.executeUpdate(); + } + catch (SQLException e) + { + InsertSqlException e1 = new InsertSqlException(insertContext.getTable(), insertContext.getDataIndex(), e); + + if (impt.isAbortOnError()) + throw e1; + else + { + if (impt.hasImportReporter()) + impt.getImportReporter().report(e1); + } + } + finally + { + insertContext.incrementDataIndex(); + + insertContext.clearCloseResources(); + } } /** * 设置插入预编译SQL语句{@linkplain PreparedStatement}参数。 + *

+ * 如果{@linkplain AbstractTextImport#isAbortOnError()}为{@code false}，此方法将不会抛出{@linkplain SetInsertPreparedColumnValueException}。 + *

* * @param impt * @param st - * @param parameterColumnInfos - * @param parameterValues - * @param setParameterContext - * @throws SQLException + * @param columnInfos + * @param columnValues + * @param insertContext + * @throws SetInsertPreparedColumnValueException */ - protected void setInsertPreparedStatementParameters(AbstractTextImport impt, PreparedStatement st, - ColumnInfo[] parameterColumnInfos, String[] parameterValues, SetParameterContext setParameterContext) - throws SQLException + protected void setInsertPreparedColumnValues(AbstractTextImport impt, PreparedStatement st, + ColumnInfo[] columnInfos, String[] columnValues, InsertContext insertContext) + throws SetInsertPreparedColumnValueException { - for (int i = 0; i < parameterColumnInfos.length; i++) - { - ColumnInfo columnInfo = parameterColumnInfos[i]; - String rawValue = (parameterValues == null || parameterValues.length - 1 < i ? null : parameterValues[i]); + boolean abortOnError = impt.isAbortOnError(); + ImportReporter importReporter = (impt.hasImportReporter() ? impt.getImportReporter() : null); + String table = insertContext.getTable(); + int dataIndex = insertContext.getDataIndex(); - setPreparedStatementParameter(impt.getConnection(), st, i + 1, columnInfo.getType(), rawValue, - setParameterContext); + for (int i = 0; i < columnInfos.length; i++) + { + ColumnInfo columnInfo = columnInfos[i]; + String columnName = columnInfo.getName(); + int sqlType = columnInfo.getType(); + int parameterIndex = i + 1; + String rawValue = (columnValues == null || columnValues.length - 1 < i ? null : columnValues[i]); + + try + { + setPreparedStatementParameter(impt.getConnection(), st, parameterIndex, sqlType, rawValue, + insertContext); + } + catch (SQLException e) + { + SetInsertPreparedColumnValueException e1 = new SetInsertPreparedColumnValueException(table, dataIndex, + columnName, rawValue, e); + + if (abortOnError) + throw e1; + else + { + setParameterNull(st, parameterIndex, sqlType); + + if (importReporter != null) + importReporter.report(e1); + } + } + catch (ParseException e) + { + IllegalSourceValueException e1 = new IllegalSourceValueException(table, dataIndex, columnName, rawValue, + e); + + if (abortOnError) + throw e1; + else + { + setParameterNull(st, parameterIndex, sqlType); + + if (importReporter != null) + importReporter.report(e1); + } + } + catch (DecoderException e) + { + IllegalSourceValueException e1 = new IllegalSourceValueException(table, dataIndex, columnName, rawValue, + e); + + if (abortOnError) + throw e1; + else + { + setParameterNull(st, parameterIndex, sqlType); + + if (importReporter != null) + importReporter.report(e1); + } + } + catch (UnsupportedSqlTypeException e) + { + SetInsertPreparedColumnValueException e1 = new SetInsertPreparedColumnValueException(table, dataIndex, + columnName, rawValue, e); + + if (abortOnError) + throw e1; + else + { + setParameterNull(st, parameterIndex, sqlType); + + if (importReporter != null) + importReporter.report(e1); + } + } + catch (Exception e) + { + SetInsertPreparedColumnValueException e1 = new SetInsertPreparedColumnValueException(table, dataIndex, + columnName, rawValue, e); + + if (abortOnError) + throw e1; + else + { + setParameterNull(st, parameterIndex, sqlType); + + if (importReporter != null) + importReporter.report(e1); + } + } + } + } + + /** + * 设置{@linkplain PreparedStatement}参数{@code null}。 + * + * @param st + * @param parameterIndex + * @param sqlType + */ + protected void setParameterNull(PreparedStatement st, int parameterIndex, int sqlType) + { + try + { + st.setNull(parameterIndex, sqlType); + } + catch (SQLException e) + { + LOGGER.error("set PreparedStatement parameter null for sql type [" + sqlType + "]", e); } } @@ -92,10 +242,14 @@ public abstract class AbstractTextDevotedDataImporter extends * @param sqlType * @param parameterValue * @param setParameterContext - * @throws Exception + * @throws SQLException + * @throws ParseException + * @throws DecoderException + * @throws UnsupportedSqlTypeException */ protected void setPreparedStatementParameter(Connection cn, PreparedStatement st, int parameterIndex, int sqlType, - String parameterValue, SetParameterContext setParameterContext) throws Exception + String parameterValue, InsertContext setParameterContext) + throws SQLException, ParseException, DecoderException, UnsupportedSqlTypeException { if (parameterValue == null) { @@ -255,7 +409,7 @@ public abstract class AbstractTextDevotedDataImporter extends default: - throw new DataImportException("The JDBC sql type [" + sqlType + "] is not supported"); + throw new UnsupportedSqlTypeException(sqlType); } } @@ -328,20 +482,88 @@ public abstract class AbstractTextDevotedDataImporter extends return Base64.decodeBase64(value); } + /** + * 移除{@code null}列信息位置对应的列值。 + * + * @param rawColumnInfos + * @param noNullColumnInfos + * @param rawColumnValues + * @return + */ + protected String[] removeNullColumnInfoValues(ColumnInfo[] rawColumnInfos, ColumnInfo[] noNullColumnInfos, + String[] rawColumnValues) + { + if (noNullColumnInfos == rawColumnInfos || noNullColumnInfos.length == rawColumnInfos.length) + return rawColumnValues; + + String[] newColumnValues = new String[noNullColumnInfos.length]; + + int index = 0; + + for (int i = 0; i < rawColumnInfos.length; i++) + { + if (rawColumnInfos[i] == null) + continue; + + newColumnValues[index++] = rawColumnValues[i]; + } + + return newColumnValues; + } + + /** + * 移除{@linkplain ColumnInfo}数组中的{@code null}元素。 + *

+ * 如果没有{@code null}元素，将返回原数组。 + *

+ * + * @param columnInfos + * @return + */ + protected ColumnInfo[] removeNulls(ColumnInfo[] columnInfos) + { + boolean noNull = true; + + for (ColumnInfo columnInfo : columnInfos) + { + if (columnInfo == null) + { + noNull = false; + break; + } + } + + if (noNull) + return columnInfos; + + List list = new ArrayList(columnInfos.length); + + for (ColumnInfo columnInfo : columnInfos) + { + if (columnInfo != null) + list.add(columnInfo); + } + + return list.toArray(new ColumnInfo[list.size()]); + } + /** * 获取表指定列信息数组。 *

- * 如果指定位置的列不存在，返回数组对应位置将为{@code null}。 + * 当指定位置的列不存在时，如果{@code nullIfInexistentColumn}为{@code true}，返回数组对应位置将为{@code null}， + * 否则，将立刻抛出{@linkplain ColumnNotFoundException}。 *

* * @param cn * @param table * @param columnNames + * @param nullIfInexistentColumn * @param databaseInfoResolver * @return + * @throws ColumnNotFoundException */ protected ColumnInfo[] getColumnInfos(Connection cn, String table, String[] columnNames, - DatabaseInfoResolver databaseInfoResolver) + boolean nullIfInexistentColumn, DatabaseInfoResolver databaseInfoResolver) throws ColumnNotFoundException { ColumnInfo[] columnInfos = new ColumnInfo[columnNames.length]; @@ -360,6 +582,9 @@ public abstract class AbstractTextDevotedDataImporter extends } } + if (!nullIfInexistentColumn && columnInfo == null) + throw new ColumnNotFoundException(table, columnNames[i]); + columnInfos[i] = columnInfo; } @@ -367,23 +592,56 @@ public abstract class AbstractTextDevotedDataImporter extends } /** - * 设置{@linkplain PreparedStatement}参数支持上下文。 + * 插入SQL语句{@linkplain PreparedStatement}参数支持上下文。 * * @author datagear@163.com * */ - protected static class SetParameterContext extends DataFormatContext + protected static class InsertContext extends DataFormatContext { private List closeResources = new LinkedList(); - public SetParameterContext() + private String table; + + private int dataIndex = 0; + + public InsertContext() { super(); } - public SetParameterContext(DataFormat dataFormat) + public InsertContext(DataFormat dataFormat, String table) { super(dataFormat); + this.table = table; + } + + public String getTable() + { + return table; + } + + public void setTable(String table) + { + this.table = table; + } + + public int getDataIndex() + { + return dataIndex; + } + + public void setDataIndex(int dataIndex) + { + this.dataIndex = dataIndex; + } + + /** + * 数据索引加{@code 1}。 + */ + public void incrementDataIndex() + { + this.dataIndex += 1; } /** diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextImport.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextImport.java index e3da0688..ec7ced65 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextImport.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/AbstractTextImport.java @@ -8,6 +8,7 @@ import java.io.Reader; import java.sql.Connection; import org.datagear.dataexchange.Import; +import org.datagear.dataexchange.ImportReporter; /** * 抽象文本数据导入。 @@ -23,16 +24,21 @@ public abstract class AbstractTextImport extends Import /** 文本数据格式 */ private DataFormat dataFormat; + /** 是否忽略不存在的列 */ + private boolean ignoreInexistentColumn; + public AbstractTextImport() { super(); } - public AbstractTextImport(Connection connection, boolean abortOnError, Reader reader, DataFormat dataFormat) + public AbstractTextImport(Connection connection, boolean abortOnError, ImportReporter importReporter, Reader reader, + DataFormat dataFormat, boolean ignoreInexistentColumn) { - super(connection, abortOnError); + super(connection, abortOnError, importReporter); this.reader = reader; this.dataFormat = dataFormat; + this.ignoreInexistentColumn = ignoreInexistentColumn; } public Reader getReader() @@ -54,4 +60,14 @@ public abstract class AbstractTextImport extends Import { this.dataFormat = dataFormat; } + + public boolean isIgnoreInexistentColumn() + { + return ignoreInexistentColumn; + } + + public void setIgnoreInexistentColumn(boolean ignoreInexistentColumn) + { + this.ignoreInexistentColumn = ignoreInexistentColumn; + } } diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvDataImporter.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvDataImporter.java index 57da9167..8a574255 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvDataImporter.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvDataImporter.java @@ -58,29 +58,38 @@ public class CsvDataImporter extends AbstractTextDevotedDataImporter long startTime = System.currentTimeMillis(); CSVParser csvParser = buildCSVParser(impt); - SetParameterContext setParameterContext = buildSetParameterContext(impt); + InsertContext insertContext = buildInsertContext(impt, impt.getTable()); Connection cn = impt.getConnection(); - ColumnInfo[] columnInfos = null; + ColumnInfo[] rawColumnInfos = null; + ColumnInfo[] noNullColumnInfos = null; + PreparedStatement st = null; try { for (CSVRecord csvRecord : csvParser) { - if (columnInfos == null) + if (rawColumnInfos == null) { - columnInfos = resolveColumnInfos(impt, csvRecord); - String sql = buildInsertPreparedSql(cn, impt.getTable(), columnInfos); + rawColumnInfos = resolveColumnInfos(impt, csvRecord); + noNullColumnInfos = removeNulls(rawColumnInfos); + + // 没有任何列 + if (noNullColumnInfos == null || noNullColumnInfos.length == 0) + throw new NoneColumnFoundException(impt.getTable()); + + String sql = buildInsertPreparedSql(cn, impt.getTable(), noNullColumnInfos); st = cn.prepareStatement(sql); } else { - String[] recordValues = resolveCSVRecordValues(impt, csvRecord); - setPreparedStatementParameters(impt, st, columnInfos, recordValues, setParameterContext); + String[] columnnValues = resolveCSVRecordValues(impt, csvRecord, rawColumnInfos, noNullColumnInfos); - st.executeUpdate(); + setInsertPreparedColumnValues(impt, st, noNullColumnInfos, columnnValues, insertContext); + + executeInsertPreparedStatement(impt, st, insertContext); } } } @@ -100,6 +109,10 @@ public class CsvDataImporter extends AbstractTextDevotedDataImporter /** * 从{@linkplain CSVRecord}解析列信息数组。 + *

+ * 当指定名称的列不存在时，如果{@code CsvImport#isIgnoreInexistentColumn()}为{@code true}，返回数组对应位置将为{@code null}， + * 否则，将立刻抛出{@linkplain ColumnNotFoundException}。 + *

* * @param impt * @param csvRecord @@ -110,7 +123,25 @@ public class CsvDataImporter extends AbstractTextDevotedDataImporter { String[] columnNames = resolveCSVRecordValues(impt, csvRecord); - return getColumnInfos(impt.getConnection(), impt.getTable(), columnNames, this.databaseInfoResolver); + return getColumnInfos(impt.getConnection(), impt.getTable(), columnNames, impt.isIgnoreInexistentColumn(), + this.databaseInfoResolver); + } + + /** + * 解析{@linkplain CSVRecord}值数组。 + * + * @param impt + * @param csvRecord + * @param rawColumnInfos + * @param noNullColumnInfos + * @return + */ + protected String[] resolveCSVRecordValues(CsvImport impt, CSVRecord csvRecord, ColumnInfo[] rawColumnInfos, + ColumnInfo[] noNullColumnInfos) + { + String[] values = resolveCSVRecordValues(impt, csvRecord); + + return removeNullColumnInfoValues(rawColumnInfos, noNullColumnInfos, values); } /** diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvImport.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvImport.java index d6822179..4ad17781 100644 --- a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvImport.java +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/CsvImport.java @@ -7,6 +7,8 @@ package org.datagear.dataexchange.support; import java.io.Reader; import java.sql.Connection; +import org.datagear.dataexchange.ImportReporter; + /** * CSV导入。 * @@ -23,9 +25,10 @@ public class CsvImport extends AbstractTextImport super(); } - public CsvImport(Connection connection, boolean abortOnError, Reader reader, DataFormat dataFormat, String table) + public CsvImport(Connection connection, boolean abortOnError, ImportReporter importReporter, Reader reader, + DataFormat dataFormat, boolean ignoreInexistentColumn, String table) { - super(connection, abortOnError, reader, dataFormat); + super(connection, abortOnError, importReporter, reader, dataFormat, ignoreInexistentColumn); this.table = table; } diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/ExceptionResolve.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/ExceptionResolve.java new file mode 100644 index 00000000..e969d776 --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/ExceptionResolve.java @@ -0,0 +1,23 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +/** + * JDBC操作异常处理方式。 + * + * @author datagear@163.com + * + */ +public enum ExceptionResolve +{ + /** 提交并终止 */ + ABORT, + + /** 忽略并继续 */ + IGNORE, + + /** 回滚并终止 */ + ROLLBACK +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/IllegalSourceValueException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/IllegalSourceValueException.java new file mode 100644 index 00000000..5d087302 --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/IllegalSourceValueException.java @@ -0,0 +1,39 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +/** + * 导入源值不合法异常。 + * + * @author datagear@163.com + * + */ +public class IllegalSourceValueException extends SetInsertPreparedColumnValueException +{ + private static final long serialVersionUID = 1L; + + public IllegalSourceValueException(String table, int dataIndex, String columnName, Object sourceValue) + { + super(table, dataIndex, columnName, sourceValue); + } + + public IllegalSourceValueException(String table, int dataIndex, String columnName, Object sourceValue, + String message) + { + super(table, dataIndex, columnName, sourceValue, message); + } + + public IllegalSourceValueException(String table, int dataIndex, String columnName, Object sourceValue, + Throwable cause) + { + super(table, dataIndex, columnName, sourceValue, cause); + } + + public IllegalSourceValueException(String table, int dataIndex, String columnName, Object sourceValue, + String message, Throwable cause) + { + super(table, dataIndex, columnName, sourceValue, message, cause); + } +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/InsertSqlException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/InsertSqlException.java new file mode 100644 index 00000000..01495fac --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/InsertSqlException.java @@ -0,0 +1,56 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +import java.sql.SQLException; + +import org.datagear.dataexchange.DataImportException; + +/** + * 导入时执行插入SQL异常。 + * + * @author datagear@163.com + * + */ +public class InsertSqlException extends DataImportException +{ + private static final long serialVersionUID = 1L; + + private String table; + + private int dataIndex; + + public InsertSqlException(String table, int dataIndex, SQLException e) + { + super(e); + this.table = table; + this.dataIndex = dataIndex; + } + + public String getTable() + { + return table; + } + + protected void setTable(String table) + { + this.table = table; + } + + public int getDataIndex() + { + return dataIndex; + } + + protected void setDataIndex(int dataIndex) + { + this.dataIndex = dataIndex; + } + + public SQLException getSQLException() + { + return (SQLException) getCause(); + } +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/NoneColumnFoundException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/NoneColumnFoundException.java new file mode 100644 index 00000000..3850547c --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/NoneColumnFoundException.java @@ -0,0 +1,54 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +import org.datagear.dataexchange.DataImportException; + +/** + * 导入数据时，在表中没有找到任何对应列异常。 + * + * @author datagear@163.com + * + */ +public class NoneColumnFoundException extends DataImportException +{ + private static final long serialVersionUID = 1L; + + private String table; + + public NoneColumnFoundException(String table) + { + super(); + this.table = table; + } + + public NoneColumnFoundException(String table, String message) + { + super(message); + this.table = table; + } + + public NoneColumnFoundException(String table, Throwable cause) + { + super(cause); + this.table = table; + } + + public NoneColumnFoundException(String table, String message, Throwable cause) + { + super(message, cause); + this.table = table; + } + + public String getTable() + { + return table; + } + + protected void setTable(String table) + { + this.table = table; + } +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/SetInsertPreparedColumnValueException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/SetInsertPreparedColumnValueException.java new file mode 100644 index 00000000..8312616b --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/SetInsertPreparedColumnValueException.java @@ -0,0 +1,107 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +import java.sql.PreparedStatement; + +import org.datagear.dataexchange.DataImportException; + +/** + * 导入数据时，设置{@linkplain PreparedStatement}列值异常。 + * + * @author datagear@163.com + * + */ +public class SetInsertPreparedColumnValueException extends DataImportException +{ + private static final long serialVersionUID = 1L; + + private String table; + + private int dataIndex; + + private String columnName; + + private Object sourceValue; + + public SetInsertPreparedColumnValueException(String table, int dataIndex, String columnName, Object sourceValue) + { + super(); + this.table = table; + this.dataIndex = dataIndex; + this.columnName = columnName; + this.sourceValue = sourceValue; + } + + public SetInsertPreparedColumnValueException(String table, int dataIndex, String columnName, Object sourceValue, + String message) + { + super(message); + this.table = table; + this.dataIndex = dataIndex; + this.columnName = columnName; + this.sourceValue = sourceValue; + } + + public SetInsertPreparedColumnValueException(String table, int dataIndex, String columnName, Object sourceValue, + Throwable cause) + { + super(cause); + this.table = table; + this.dataIndex = dataIndex; + this.columnName = columnName; + this.sourceValue = sourceValue; + } + + public SetInsertPreparedColumnValueException(String table, int dataIndex, String columnName, Object sourceValue, + String message, Throwable cause) + { + super(message, cause); + this.table = table; + this.dataIndex = dataIndex; + this.columnName = columnName; + this.sourceValue = sourceValue; + } + + public String getTable() + { + return table; + } + + protected void setTable(String table) + { + this.table = table; + } + + public int getDataIndex() + { + return dataIndex; + } + + protected void setDataIndex(int dataIndex) + { + this.dataIndex = dataIndex; + } + + public String getColumnName() + { + return columnName; + } + + public void setColumnName(String columnName) + { + this.columnName = columnName; + } + + public Object getSourceValue() + { + return sourceValue; + } + + protected void setSourceValue(Object sourceValue) + { + this.sourceValue = sourceValue; + } +} diff --git a/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/UnsupportedSqlTypeException.java b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/UnsupportedSqlTypeException.java new file mode 100644 index 00000000..20af1f94 --- /dev/null +++ b/datagear-dataexchange/src/main/java/org/datagear/dataexchange/support/UnsupportedSqlTypeException.java @@ -0,0 +1,52 @@ +/* + * Copyright (c) 2018 datagear.org. All Rights Reserved. + */ + +package org.datagear.dataexchange.support; + +/** + * 不支持指定SQL类型异常。 + * + * @author datagear@163.com + * + */ +public class UnsupportedSqlTypeException extends Exception +{ + private static final long serialVersionUID = 1L; + + private int sqlType; + + public UnsupportedSqlTypeException(int sqlType) + { + super("Import data of JDBC sql type [" + sqlType + "] is not supported"); + this.sqlType = sqlType; + } + + public UnsupportedSqlTypeException(int sqlType, String message) + { + super(message); + this.sqlType = sqlType; + } + + public UnsupportedSqlTypeException(int sqlType, Throwable cause) + { + super(cause); + this.sqlType = sqlType; + } + + public UnsupportedSqlTypeException(int sqlType, String message, Throwable cause) + { + super(message, cause); + this.sqlType = sqlType; + } + + public int getSqlType() + { + return sqlType; + } + + protected void setSqlType(int sqlType) + { + this.sqlType = sqlType; + } +}