This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 33f5a86e69 [fix](array-type) forbid to create materialized view for
array column (#12543)
add 22a8d35999 [Feature](vectorized) support jdbc sink for insert into
data to table (#12534)
No new revisions were added by this update.
Summary of changes:
be/src/exec/CMakeLists.txt | 1 +
be/src/exec/data_sink.cpp | 17 ++
be/src/exec/odbc_connector.cpp | 252 +-----------------
be/src/exec/odbc_connector.h | 67 +----
be/src/exec/table_connector.cpp | 296 +++++++++++++++++++++
.../exec/{odbc_connector.h => table_connector.h} | 99 ++-----
be/src/runtime/odbc_table_sink.cpp | 7 +-
be/src/vec/CMakeLists.txt | 2 +
be/src/vec/exec/vjdbc_connector.cpp | 70 ++++-
be/src/vec/exec/vjdbc_connector.h | 28 +-
be/src/vec/exec/vjdbc_scan_node.cpp | 2 +-
be/src/vec/sink/vjdbc_table_sink.cpp | 102 +++++++
.../vinfo_func.h => sink/vjdbc_table_sink.h} | 41 ++-
be/src/vec/sink/vmysql_table_sink.cpp | 40 +--
be/src/vec/sink/vmysql_table_sink.h | 34 +--
be/src/vec/sink/vodbc_table_sink.cpp | 49 ++--
be/src/vec/sink/vodbc_table_sink.h | 31 +--
be/src/vec/sink/vtable_sink.cpp | 74 ++++++
.../vec/sink/{vodbc_table_sink.h => vtable_sink.h} | 20 +-
.../docs/ecosystem/external-table/jdbc-of-doris.md | 22 +-
.../docs/ecosystem/external-table/jdbc-of-doris.md | 45 +++-
.../org/apache/doris/analysis/DescribeStmt.java | 8 +
.../java/org/apache/doris/analysis/ExportStmt.java | 1 +
.../java/org/apache/doris/analysis/InsertStmt.java | 4 +-
.../org/apache/doris/catalog/JdbcResource.java | 14 +-
.../java/org/apache/doris/catalog/JdbcTable.java | 129 +++++++--
.../main/java/org/apache/doris/load/ExportJob.java | 6 +
.../java/org/apache/doris/planner/DataSink.java | 3 +
.../apache/doris/planner/DistributedPlanner.java | 2 +-
.../org/apache/doris/planner/JdbcTableSink.java | 102 +++++++
.../java/org/apache/doris/udf/JdbcExecutor.java | 35 ++-
gensrc/thrift/DataSinks.thrift | 7 +
32 files changed, 1011 insertions(+), 599 deletions(-)
create mode 100644 be/src/exec/table_connector.cpp
copy be/src/exec/{odbc_connector.h => table_connector.h} (50%)
create mode 100644 be/src/vec/sink/vjdbc_table_sink.cpp
copy be/src/vec/{exprs/vinfo_func.h => sink/vjdbc_table_sink.h} (58%)
create mode 100644 be/src/vec/sink/vtable_sink.cpp
copy be/src/vec/sink/{vodbc_table_sink.h => vtable_sink.h} (79%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/JdbcTableSink.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
