SQLServer

Overview

The SQLServer Load Node supports to write data into SQLServer database. This document describes how to set up the SQLServer Load Node to run SQL queries against SQLServer database.

Supported Version

Dependencies

In order to set up the SQLServer Load Node, the following provides dependency information for both projects using a build automation tool (such as Maven or SBT) and SQL Client with Sort Connectors JAR bundles.

Maven dependency

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

How to create an SQLServer Load Node

Usage for 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 node
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'
)
-- write data into SQLServer
INSERT INTO sqlserver_load_table 
SELECT id, name , age FROM mysql_extract_table;

Usage for InLong Dashboard

TODO: It will be supported in the future.

Usage for InLong Manager Client

TODO: It will be supported in the future.

SQLServer Load Node Options

Data Type Mapping