You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ur...@apache.org on 2022/10/18 12:01:46 UTC
[pulsar-site] branch main updated: Docs sync done from apache/pulsar(#ff44420)
This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new d106114d2af Docs sync done from apache/pulsar(#ff44420)
d106114d2af is described below
commit d106114d2af6cf820a496b2db59c8d67747ac38b
Author: Pulsar Site Updater <de...@pulsar.apache.org>
AuthorDate: Tue Oct 18 12:01:39 2022 +0000
Docs sync done from apache/pulsar(#ff44420)
---
site2/website-next/docs/io-jdbc-sink.md | 27 ++++++++++++++-------------
1 file changed, 14 insertions(+), 13 deletions(-)
diff --git a/site2/website-next/docs/io-jdbc-sink.md b/site2/website-next/docs/io-jdbc-sink.md
index c16234f20b8..4c9a473e027 100644
--- a/site2/website-next/docs/io-jdbc-sink.md
+++ b/site2/website-next/docs/io-jdbc-sink.md
@@ -15,19 +15,20 @@ The configuration of all JDBC sink connectors has the following properties.
### Property
-| Name | Type | Required | Default | Description |
-|-------------|--------|----------|--------------------|--------------------------------------------------------------------------------------------------------------------------|
-| `userName` | String | false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br /><br />**Note: `userName` is case-sensitive.** |
-| `password` | String | false | " " (empty string) | The password used to connect to the database specified by `jdbcUrl`. <br /><br />**Note: `password` is case-sensitive.** |
-| `jdbcUrl` | String | true | " " (empty string) | The JDBC URL of the database that the connector connects to. |
-| `tableName` | String | true | " " (empty string) | The name of the table that the connector writes to. |
-| `nonKey` | String | false | " " (empty string) | A comma-separated list containing the fields used in updating events. |
-| `key` | String | false | " " (empty string) | A comma-separated list containing the fields used in `where` condition of updating and deleting events. |
-| `timeoutMs` | int | false | 500 | The JDBC operation timeout in milliseconds. |
-| `batchSize` | int | false | 200 | The batch size of updates made to the database. |
-| `insertMode` | enum( INSERT,UPSERT,UPDATE) | false | INSERT | If it is configured as UPSERT, the sink uses upsert semantics rather than plain INSERT/UPDATE statements. Upsert semantics refer to atomically adding a new row or updating the existing row if there is a primary key constraint violation, which provides idempotence. |
-| `nullValueAction` | enum(FAIL, DELETE) | false | FAIL | How to handle records with NULL values. Possible options are `DELETE` or `FAIL`. |
-| `useTransactions` | boolean | false | true | Enable transactions of the database.
+| Name | Type | Required | Default | Description |
+|-------------|--------|----------|--------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| `userName` | String | false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br /><br />**Note: `userName` is case-sensitive.** |
+| `password` | String | false | " " (empty string) | The password used to connect to the database specified by `jdbcUrl`. <br /><br />**Note: `password` is case-sensitive.** |
+| `jdbcUrl` | String | true | " " (empty string) | The JDBC URL of the database that the connector connects to. |
+| `tableName` | String | true | " " (empty string) | The name of the table that the connector writes to. |
+| `nonKey` | String | false | " " (empty string) | A comma-separated list containing the fields used in updating events. |
+| `key` | String | false | " " (empty string) | A comma-separated list containing the fields used in `where` condition of updating and deleting events. |
+| `timeoutMs` | int | false | 500 | The JDBC operation timeout in milliseconds. |
+| `batchSize` | int | false | 200 | The batch size of updates made to the database. |
+| `insertMode` | enum( INSERT,UPSERT,UPDATE) | false | INSERT | If it is configured as UPSERT, the sink uses upsert semantics rather than plain INSERT/UPDATE statements. Upsert semantics refer to atomically adding a new row or updating the existing row if there is a primary key constraint violation, which provides idempotence. |
+| `nullValueAction` | enum(FAIL, DELETE) | false | FAIL | How to handle records with NULL values. Possible options are `DELETE` or `FAIL`. |
+| `useTransactions` | boolean | false | true | Enable transactions of the database.
+| `excludeNonDeclaredFields` | boolean | false | false | All the table fields are discovered automatically. `excludeNonDeclaredFields` indicates if the table fields not explicitly listed in `nonKey` and `key` must be included in the query. By default all the table fields are included. To leverage of table fields defaults during insertion, it is suggested to set this value to `false`. |
### Example of ClickHouse