liyafan82 commented on code in PR #13589:
URL: https://github.com/apache/arrow/pull/13589#discussion_r927493603
##########
docs/source/java/jdbc.rst:
##########
@@ -84,8 +84,8 @@ inconsistent scale. A RoundingMode can be set to handle these
cases:
}
}
-Currently, it is not possible to define a custom type conversion for a
-supported or unsupported type.
+Currently, it is not possible to override the type conversion for a
+supported type, or define a new conversion for an unsupported type.
Review Comment:
Thanks.
##########
docs/source/java/jdbc.rst:
##########
@@ -172,3 +172,101 @@ The JDBC to Arrow type mapping can be obtained at runtime
from
.. _setArraySubTypeByColumnIndexMap:
https://arrow.apache.org/docs/java/reference/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.html#setArraySubTypeByColumnIndexMap-java.util.Map-
.. _setArraySubTypeByColumnNameMap:
https://arrow.apache.org/docs/java/reference/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.html#setArraySubTypeByColumnNameMap-java.util.Map-
.. _ARROW-17006: https://issues.apache.org/jira/browse/ARROW-17006
+
+VectorSchemaRoot to PreparedStatement Parameter Conversion
+==========================================================
+
+The adapter can bind rows of Arrow data from a VectorSchemaRoot to
+parameters of a JDBC PreparedStatement. This can be accessed via the
+JdbcParameterBinder class. Each call to next() will bind parameters
+from the next row of data, and then the application can execute the
+statement, call addBatch(), etc. as desired. Null values will lead to
+a setNull call with an appropriate JDBC type code (listed below).
+
+.. code-block:: java
+
+ final JdbcParameterBinder binder =
+ JdbcParameterBinder.builder(statement, root).bindAll().build();
+ while (binder.next()) {
+ statement.executeUpdate();
+ }
+ // Use a VectorLoader to update the root
+ binder.reset();
+ while (binder.next()) {
+ statement.executeUpdate();
+ }
+
+The mapping of vectors to parameters, the JDBC type code used by the
+converters, and the type conversions themselves can all be customized:
+
+.. code-block:: java
+
+ final JdbcParameterBinder binder =
+ JdbcParameterBinder.builder(statement, root)
+ .bind(/*parameterIndex*/2, /*columnIndex*/0)
+ .bind(/*parameterIndex*/1, customColumnBinderInstance)
+ .build();
+
+Type Mapping
+------------
+
+The Arrow to JDBC type mapping can be obtained at runtime via
+a method on ColumnBinder.
+
++----------------------------+----------------------------+-------+
+| Arrow Type | JDBC Type | Notes |
++============================+============================+=======+
+| Binary | VARBINARY (setBytes) | |
++----------------------------+----------------------------+-------+
+| Bool | BOOLEAN (setBoolean) | |
++----------------------------+----------------------------+-------+
+| Date32 | DATE (setDate) | |
++----------------------------+----------------------------+-------+
+| Date64 | DATE (setDate) | |
++----------------------------+----------------------------+-------+
+| Decimal128 | DECIMAL (setBigDecimal) | |
++----------------------------+----------------------------+-------+
+| Decimal256 | DECIMAL (setBigDecimal) | |
++----------------------------+----------------------------+-------+
+| FixedSizeBinary | BINARY (setBytes) | |
++----------------------------+----------------------------+-------+
+| Float32 | REAL (setFloat) | |
++----------------------------+----------------------------+-------+
+| Int8 | TINYINT (setByte) | |
++----------------------------+----------------------------+-------+
+| Int16 | SMALLINT (setShort) | |
++----------------------------+----------------------------+-------+
+| Int32 | INTEGER (setInt) | |
++----------------------------+----------------------------+-------+
+| Int64 | BIGINT (setLong) | |
++----------------------------+----------------------------+-------+
+| LargeBinary | LONGVARBINARY (setBytes) | |
++----------------------------+----------------------------+-------+
+| LargeUtf8 | LONGVARCHAR (setString) | \(1) |
++----------------------------+----------------------------+-------+
+| Time[s] | TIME (setTime) | |
++----------------------------+----------------------------+-------+
+| Time[ms] | TIME (setTime) | |
++----------------------------+----------------------------+-------+
+| Time[us] | TIME (setTime) | |
++----------------------------+----------------------------+-------+
+| Time[ns] | TIME (setTime) | |
++----------------------------+----------------------------+-------+
+| Timestamp[s] | TIMESTAMP (setTimestamp) | \(2) |
++----------------------------+----------------------------+-------+
+| Timestamp[ms] | TIMESTAMP (setTimestamp) | \(2) |
++----------------------------+----------------------------+-------+
+| Timestamp[us] | TIMESTAMP (setTimestamp) | \(2) |
++----------------------------+----------------------------+-------+
+| Timestamp[ns] | TIMESTAMP (setTimestamp) | \(2) |
++----------------------------+----------------------------+-------+
+| Utf8 | VARCHAR (setString) | |
++----------------------------+----------------------------+-------+
+
+* \(1) Strings longer than Integer.MAX_VALUE bytes (the maximum length
+ of a Java ``byte[]``) will cause a runtime exception.
+* \(2) If the timestamp has a timezone, the JDBC type defaults to
+ TIMESTAMP_WITH_TIMEZONE. If the timestamp has no timezone,
Review Comment:
Thanks for the clarification.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
