SQLServer

概览

SQLServer Load 节点支持将数据写入 SQLServer 数据库。 本文档介绍如何设置 SQLServer Load 节点以对 SQLServer 数据库运行 SQL 查询。

支持的版本

依赖

为了设置 SQLServer Load 节点, 下面提供了使用构建自动化工具（例如 Maven 或 SBT）和带有 Sort Connector JAR 包的 SQL 客户端的两个项目的依赖关系信息。

Maven 依赖

<dependency>
    <groupId>org.apache.inlong</groupId>
    <artifactId>sort-connector-jdbc</artifactId>
    <version>2.1.0-SNAPSHOT</version>
</dependency>

如何创建 SQLServer Load 节点

SQL API 用法

-- SQLServer extract node
CREATE TABLE `sqlserver_extract_table`(
      PRIMARY KEY (`id`) NOT ENFORCED,
      `id` BIGINT,
      `name` STRING,
      `age` INT
) WITH (
      'connector' = 'sqlserver-cdc-inlong',
      'url' = 'jdbc:sqlserver://localhost:1433/read',
      'username' = 'inlong',
      'password' = 'inlong',
      'table-name' = 'dbo.user'
      )
-- SQLServer Load 节点
CREATE TABLE `sqlserver_load_table`(
  PRIMARY KEY (`id`) NOT ENFORCED,
  `id` BIGINT,
  `name` STRING,
  `age` INT
) WITH (
  'connector' = 'jdbc-inlong',
  'url' = 'jdbc:sqlserver://localhost:1433;databaseName=column_type_test',
  'username' = 'inlong',
  'password' = 'inlong',
  'table-name' = 'dbo.work1'
)
-- 写数据到 SQLServer
INSERT INTO sqlserver_load_table 
SELECT id, name , age FROM mysql_extract_table;

InLong Dashboard 用法

TODO: 将在未来支持此功能。

InLong Manager Client 用法

TODO: 将在未来支持此功能。

SQLServer Load 节点参数

数据映射