You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/12/03 16:02:49 UTC
nifi git commit: NIFI-1241: Incorporate Boolean, Numeric,
and Decimal data types for PutSQL
Repository: nifi
Updated Branches:
refs/heads/master 6b75eda9a -> eceb1d20c
NIFI-1241: Incorporate Boolean, Numeric, and Decimal data types for PutSQL
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/eceb1d20
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/eceb1d20
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/eceb1d20
Branch: refs/heads/master
Commit: eceb1d20c771cdadc7c1ee8dfefa7abdf9726e42
Parents: 6b75eda
Author: Mark Payne <ma...@hotmail.com>
Authored: Wed Dec 2 15:39:23 2015 -0500
Committer: Mark Payne <ma...@hotmail.com>
Committed: Thu Dec 3 10:02:36 2015 -0500
----------------------------------------------------------------------
.../apache/nifi/processors/standard/PutSQL.java | 47 +-------------------
1 file changed, 1 insertion(+), 46 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/eceb1d20/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java
index 7f32e54..51d9735 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java
@@ -729,52 +729,7 @@ public class PutSQL extends AbstractProcessor {
* @throws SQLException if the PreparedStatement throws a SQLException when calling the appropriate setter
*/
private void setParameter(final PreparedStatement stmt, final String attrName, final int parameterIndex, final String parameterValue, final int jdbcType) throws SQLException {
- if (parameterValue == null) {
- stmt.setNull(parameterIndex, jdbcType);
- } else {
- switch (jdbcType) {
- case Types.BIT:
- stmt.setBoolean(parameterIndex, Boolean.parseBoolean(parameterValue));
- break;
- case Types.TINYINT:
- stmt.setByte(parameterIndex, Byte.parseByte(parameterValue));
- break;
- case Types.SMALLINT:
- stmt.setShort(parameterIndex, Short.parseShort(parameterValue));
- break;
- case Types.INTEGER:
- stmt.setInt(parameterIndex, Integer.parseInt(parameterValue));
- break;
- case Types.BIGINT:
- stmt.setLong(parameterIndex, Long.parseLong(parameterValue));
- break;
- case Types.REAL:
- stmt.setFloat(parameterIndex, Float.parseFloat(parameterValue));
- break;
- case Types.FLOAT:
- case Types.DOUBLE:
- stmt.setDouble(parameterIndex, Double.parseDouble(parameterValue));
- break;
- case Types.DATE:
- stmt.setDate(parameterIndex, new Date(Long.parseLong(parameterValue)));
- break;
- case Types.TIME:
- stmt.setTime(parameterIndex, new Time(Long.parseLong(parameterValue)));
- break;
- case Types.TIMESTAMP:
- stmt.setTimestamp(parameterIndex, new Timestamp(Long.parseLong(parameterValue)));
- break;
- case Types.CHAR:
- case Types.VARCHAR:
- case Types.LONGNVARCHAR:
- case Types.LONGVARCHAR:
- stmt.setString(parameterIndex, parameterValue);
- break;
- default:
- throw new SQLException("The '" + attrName + "' attribute has a value of '" + parameterValue
- + "' and a type of '" + jdbcType + "' but this is not a known data type");
- }
- }
+ stmt.setObject(parameterIndex, parameterValue, jdbcType);
}