基于Logstash由SQLServer向Elasticsearch同步数据：环境准备【SQL Server data to Elasticsearch using LogStash】

-- 假设我们有一个名为logstash_sync_test的表，需要同步到Elasticsearch。
-- 以下是创建该表和插入一些示例数据的SQL脚本。
 
-- 创建表
CREATE TABLE [dbo].[logstash_sync_test](
    [id] [int] IDENTITY(1,1) NOT NULL,
    [name] [varchar](255)OT NULL,
    [email] [varchar](255) NOT NULL,
    [created_at] [datetime] NOT NULL,
    [updated_at] [datetime] NOT NULL,
 CONSTRAINT [PK_logstash_sync_test] PRIMARY KEY CLUSTERED 
(
    [id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]
 
-- 插入示例数据
INSERT INTO [dbo].[logstash_sync_test] ([name], [email], [created_at], [updated_at])
VALUES ('Alice', 'alice@example.com', GETDATE(), GETDATE()),
       ('Bob', 'bob@example.com', GETDATE(), GETDATE());
 
-- 注意：这里的SQL脚本仅用于创建和填充示例表，实际应用中的表结构和数据应根据实际需求设计和填充。

在这个示例中，我们创建了一个名为logstash\_sync\_test的表，并插入了两条记录。这个表将用作Logstash同步到Elasticsearch的数据源。注意，这个脚本仅用于演示，实际的数据库和表结构应根据实际需求进行设计。