139 lines
5.5 KiB
Transact-SQL
139 lines
5.5 KiB
Transact-SQL
/*
|
||
庆安数字孪生可视化看板 - 前端埋点数据库对象
|
||
目标数据库：DDV_AQ
|
||
用途：
|
||
1. 创建前端埋点日志表 dbo.TV_前端埋点事件日志
|
||
2. 创建写入存储过程 dbo.TV_前端埋点事件_写入
|
||
3. 创建清理存储过程 dbo.TV_前端埋点事件日志_清理
|
||
4. 写入时自动小批量清理 365 天以前的数据
|
||
*/
|
||
|
||
IF OBJECT_ID(N'dbo.TV_前端埋点事件日志', N'U') IS NULL
|
||
BEGIN
|
||
CREATE TABLE dbo.[TV_前端埋点事件日志]
|
||
(
|
||
[ID] BIGINT IDENTITY(1,1) NOT NULL CONSTRAINT [PK_TV_前端埋点事件日志] PRIMARY KEY,
|
||
[app_id] NVARCHAR(100) NOT NULL,
|
||
[app_version] NVARCHAR(50) NULL,
|
||
[env] NVARCHAR(20) NULL,
|
||
[page_path] NVARCHAR(500) NULL,
|
||
[referrer] NVARCHAR(500) NULL,
|
||
[trace_id] NVARCHAR(100) NULL,
|
||
[session_id] NVARCHAR(100) NULL,
|
||
[user_id] NVARCHAR(100) NULL,
|
||
[timestamp] BIGINT NULL,
|
||
[client_ip] NVARCHAR(64) NULL,
|
||
[client_info] NVARCHAR(MAX) NULL,
|
||
[event_type] NVARCHAR(50) NOT NULL,
|
||
[event_name] NVARCHAR(100) NOT NULL,
|
||
[event_level] NVARCHAR(20) NULL,
|
||
[event_data] NVARCHAR(MAX) NULL,
|
||
[duration_ms] INT NULL,
|
||
[success] BIT NULL,
|
||
[error_code] NVARCHAR(100) NULL,
|
||
[error_message] NVARCHAR(MAX) NULL,
|
||
[create_time] DATETIME2(0) NOT NULL CONSTRAINT [DF_TV_前端埋点事件日志_create_time] DEFAULT SYSDATETIME()
|
||
);
|
||
END;
|
||
GO
|
||
|
||
IF NOT EXISTS (SELECT 1 FROM sys.indexes WHERE name = N'IX_TV_前端埋点事件日志_create_time' AND object_id = OBJECT_ID(N'dbo.TV_前端埋点事件日志'))
|
||
CREATE INDEX [IX_TV_前端埋点事件日志_create_time] ON dbo.[TV_前端埋点事件日志]([create_time] DESC);
|
||
GO
|
||
|
||
IF NOT EXISTS (SELECT 1 FROM sys.indexes WHERE name = N'IX_TV_前端埋点事件日志_trace_id' AND object_id = OBJECT_ID(N'dbo.TV_前端埋点事件日志'))
|
||
CREATE INDEX [IX_TV_前端埋点事件日志_trace_id] ON dbo.[TV_前端埋点事件日志]([trace_id]);
|
||
GO
|
||
|
||
IF NOT EXISTS (SELECT 1 FROM sys.indexes WHERE name = N'IX_TV_前端埋点事件日志_session_time' AND object_id = OBJECT_ID(N'dbo.TV_前端埋点事件日志'))
|
||
CREATE INDEX [IX_TV_前端埋点事件日志_session_time] ON dbo.[TV_前端埋点事件日志]([session_id], [timestamp]);
|
||
GO
|
||
|
||
IF NOT EXISTS (SELECT 1 FROM sys.indexes WHERE name = N'IX_TV_前端埋点事件日志_event_time' AND object_id = OBJECT_ID(N'dbo.TV_前端埋点事件日志'))
|
||
CREATE INDEX [IX_TV_前端埋点事件日志_event_time] ON dbo.[TV_前端埋点事件日志]([event_name], [create_time] DESC);
|
||
GO
|
||
|
||
CREATE OR ALTER PROCEDURE dbo.[TV_前端埋点事件日志_清理]
|
||
@retention_days INT = 365,
|
||
@batch_size INT = 2000,
|
||
@return_result BIT = 1
|
||
AS
|
||
BEGIN
|
||
SET NOCOUNT ON;
|
||
|
||
DECLARE @safe_retention_days INT = CASE WHEN ISNULL(@retention_days, 365) < 1 THEN 365 ELSE @retention_days END;
|
||
DECLARE @safe_batch_size INT = CASE WHEN ISNULL(@batch_size, 2000) < 1 THEN 2000 ELSE @batch_size END;
|
||
DECLARE @cutoff_time DATETIME2(0) = DATEADD(DAY, -@safe_retention_days, SYSDATETIME());
|
||
|
||
DELETE TOP (@safe_batch_size)
|
||
FROM dbo.[TV_前端埋点事件日志]
|
||
WHERE [create_time] < @cutoff_time;
|
||
|
||
DECLARE @deleted_count INT = @@ROWCOUNT;
|
||
|
||
IF @return_result = 1
|
||
BEGIN
|
||
SELECT N'1' AS result, @deleted_count AS deleted_count, @cutoff_time AS cutoff_time;
|
||
END;
|
||
END;
|
||
GO
|
||
|
||
CREATE OR ALTER PROCEDURE dbo.[TV_前端埋点事件_写入]
|
||
@app_id NVARCHAR(100),
|
||
@app_version NVARCHAR(50) = NULL,
|
||
@env NVARCHAR(20) = NULL,
|
||
@page_path NVARCHAR(500) = NULL,
|
||
@referrer NVARCHAR(500) = NULL,
|
||
@trace_id NVARCHAR(100) = NULL,
|
||
@session_id NVARCHAR(100) = NULL,
|
||
@user_id NVARCHAR(100) = NULL,
|
||
@timestamp NVARCHAR(30) = NULL,
|
||
@client_ip NVARCHAR(64) = NULL,
|
||
@client_info NVARCHAR(MAX) = NULL,
|
||
@event_type NVARCHAR(50),
|
||
@event_name NVARCHAR(100),
|
||
@event_level NVARCHAR(20) = NULL,
|
||
@event_data NVARCHAR(MAX) = NULL,
|
||
@duration_ms NVARCHAR(30) = NULL,
|
||
@success NVARCHAR(10) = NULL,
|
||
@error_code NVARCHAR(100) = NULL,
|
||
@error_message NVARCHAR(MAX) = NULL
|
||
AS
|
||
BEGIN
|
||
SET NOCOUNT ON;
|
||
|
||
DECLARE @success_bit BIT = NULL;
|
||
IF NULLIF(LTRIM(RTRIM(@success)), N'') IS NOT NULL
|
||
BEGIN
|
||
SET @success_bit = CASE
|
||
WHEN UPPER(LTRIM(RTRIM(@success))) IN (N'1', N'TRUE', N'YES', N'是') THEN 1
|
||
ELSE 0
|
||
END;
|
||
END;
|
||
|
||
INSERT INTO dbo.[TV_前端埋点事件日志]
|
||
(
|
||
[app_id], [app_version], [env], [page_path], [referrer],
|
||
[trace_id], [session_id], [user_id], [timestamp], [client_ip],
|
||
[client_info], [event_type], [event_name], [event_level], [event_data],
|
||
[duration_ms], [success], [error_code], [error_message]
|
||
)
|
||
VALUES
|
||
(
|
||
NULLIF(@app_id, N''), NULLIF(@app_version, N''), NULLIF(@env, N''), NULLIF(@page_path, N''), NULLIF(@referrer, N''),
|
||
NULLIF(@trace_id, N''), NULLIF(@session_id, N''), NULLIF(@user_id, N''), TRY_CONVERT(BIGINT, NULLIF(@timestamp, N'')), NULLIF(@client_ip, N''),
|
||
NULLIF(@client_info, N''), NULLIF(@event_type, N''), NULLIF(@event_name, N''), NULLIF(@event_level, N''), NULLIF(@event_data, N''),
|
||
TRY_CONVERT(INT, NULLIF(@duration_ms, N'')), @success_bit, NULLIF(@error_code, N''), NULLIF(@error_message, N'')
|
||
);
|
||
|
||
DECLARE @insert_id BIGINT = CAST(SCOPE_IDENTITY() AS BIGINT);
|
||
|
||
EXEC dbo.[TV_前端埋点事件日志_清理]
|
||
@retention_days = 365,
|
||
@batch_size = 2000,
|
||
@return_result = 0;
|
||
|
||
SELECT @insert_id AS ID, N'1' AS result, N'写入成功' AS message;
|
||
END;
|
||
GO
|