SqlServer 查询数据

MS Sql Server导入插件

简介

service_mssql input插件可以采集Sql Server查询数据。

版本

配置参数

参数	类型，默认值	说明
Type	String，无默认值（必填）	插件类型，指定为`service_mssql`。
Host	String，`127.0.0.1`	数据库主机。
Port	Interger，`1433`	数据库端口。
User	String，`root`	数据库用户名。
Password	String，默认值为空	数据库密码。
Database	String，默认值为空	数据库名称。
DialTimeOutMs	Interger，5000	数据库连接超时时间，单位：ms，默认5000ms
ReadTimeOutMs	Interger，5000	数据库查询超时时间，单位：ms，默认5000ms
Statement	String，默认值为空	SQL语句。设置CheckPoint为true时，StateMent中SQL语句的where条件中必须包含CheckPointColumn，并将该列的值配置为$1。例如：CheckPointColumn配置为id，则StateMent配置为SELECT * from … where id > $1。
Limit	Boolean，`false`	是否使用Limit分页。不配置时，默认为false，表示不使用Limit分页。建议使用Limit进行分页。设置Limit为true后，进行SQL查询时，会自动在StateMent中追加LIMIT语句。
PageSize	Interger，无默认值	分页大小，Limit为true时必须配置。
MaxSyncSize	Interger，`0`	每次同步最大记录数。不配置时，默认为0，表示无限制。
CheckPoint	Boolean，`false`	是否使用checkpoint。不配置时，默认为false，表示不使用checkpoint。
CheckPointColumn	String，无默认值	checkpoint列名称。 CheckPoint为true时必须配置。注意该列的值必须递增，否则可能会出现数据漏采集问题（每次查询结果中的最大值将作为下次查询的输入）。
CheckPointColumnType	String，无默认值	checkpoint列类型，支持int和time两种类型。int类型的内部存储为int64，time类型支持MySQL的date、datetime、time。 CheckPoint为true时必须配置。
CheckPointStart	String，无默认值	checkpoint初始值。CheckPoint为true时必须配置。
CheckPointSavePerPage	Boolean，无默认值	设置为true，则每次分页时保存一次checkpoint；设置为false，则每次同步完后保存checkpoint。
IntervalMs	Interger，无默认值	同步间隔，单位：ms。

样例

Sql Server数据库创建LogtailTest数据库，LogtailTestTable表。

表结构及数据信息如下

IF NOT EXISTS(SELECT * FROM sys.databases WHERE name = 'LogtailTest')
BEGIN
    CREATE DATABASE [LogtailTest]
END
GO
USE [LogtailTest]
GO

IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='LogtailTestTable' and xtype='U')
BEGIN
    CREATE TABLE LogtailTestTable (
        id INT PRIMARY KEY IDENTITY (1, 1),
        name NVARCHAR(50),
        quantity INT
    )
END
GO

INSERT INTO LogtailTestTable (name, quantity) values('banana', 1);
INSERT INTO LogtailTestTable (name, quantity) values('banana', 2);
INSERT INTO LogtailTestTable (name, quantity) values('banana', 3);
INSERT INTO LogtailTestTable (name, quantity) values('banana', 4);
SELECT * FROM LogtailTestTable;
GO

采集配置

enable: true
inputs:
  - Type: service_mssql
    Address: 127.0.0.1
    CheckPoint: true
    CheckPointColumn: id
    CheckPointColumnType: int
    CheckPointSavePerPage: true
    CheckPointStart: "0"
    Database: LogtailTest
    IntervalMs: 1000
    Limit: true
    MaxSyncSize: 100
    PageSize: 100
    User: sa
    Password: xxxxx
    StateMent: "select * from LogtailTestTable where id > ? order by id"
flushers:
  - Type: flusher_stdout
    OnlyStdout: true

输出

{"id":"1","name":"banana","quantity":"1","__time__":"1661416452"}
{"id":"2","name":"banana","quantity":"2","__time__":"1661416452"}
{"id":"3","name":"banana","quantity":"3","__time__":"1661416452"}
{"id":"4","name":"banana","quantity":"4","__time__":"1661416452"}