From e33ee9337ff14d60eca1c91cedacce027e0323b1 Mon Sep 17 00:00:00 2001 From: sheyanjie Date: Fri, 15 Dec 2023 16:45:14 +0800 Subject: [PATCH] fix misspelling --- api/audit.go | 8 ++++---- api/audit_test.go | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/api/audit.go b/api/audit.go index f69981b..3a84bc2 100644 --- a/api/audit.go +++ b/api/audit.go @@ -19,7 +19,7 @@ var auditLogger = log.GetLogger("audit") const MAX_DETAIL_LEN = 50000 -const MAX_SQL_LEN = 1000 * 1000 +var MAX_SQL_LEN = 1000 * 1000 type Audit struct { username string @@ -188,11 +188,11 @@ func handleBatchRecord(auditArray []AuditInfo, conn *db.Connector) error { for _, audit := range auditArray { details := handleDetails(audit.Details) - varluesStr := fmt.Sprintf( + valuesStr := fmt.Sprintf( "(%s, '%s', '%s', '%s', '%s', '%s', '%s') ", audit.Timestamp, audit.User, audit.Operation, audit.Db, audit.Resource, audit.ClientAdd, details) - if (builder.Len() + len(varluesStr)) > MAX_SQL_LEN { + if (builder.Len() + len(valuesStr)) > MAX_SQL_LEN { sql := builder.String() if _, err := conn.Exec(context.Background(), sql); err != nil { return err @@ -200,7 +200,7 @@ func handleBatchRecord(auditArray []AuditInfo, conn *db.Connector) error { builder.Reset() builder.WriteString(head) } - builder.WriteString(varluesStr) + builder.WriteString(valuesStr) } if builder.Len() > len(head) { diff --git a/api/audit_test.go b/api/audit_test.go index fbd5d41..72f75ab 100644 --- a/api/audit_test.go +++ b/api/audit_test.go @@ -88,6 +88,7 @@ func TestAudit(t *testing.T) { }) } + MAX_SQL_LEN = 300 // test audit batch input := `{"records":[{"timestamp":"1702548856940013848","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45166","db":"test","resource":"","details":"d630302"},{"timestamp":"1702548856939746458","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45230","db":"test","resource":"","details":"d130277"},{"timestamp":"1702548856939586665","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:50288","db":"test","resource":"","details":"d5268"},{"timestamp":"1702548856939528940","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:50222","db":"test","resource":"","details":"d255282"},{"timestamp":"1702548856939336371","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45126","db":"test","resource":"","details":"d755297"},{"timestamp":"1702548856939075131","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45122","db":"test","resource":"","details":"d380325"},{"timestamp":"1702548856938640661","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45152","db":"test","resource":"","details":"d255281"},{"timestamp":"1702548856938505795","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45122","db":"test","resource":"","details":"d130276"},{"timestamp":"1702548856938363319","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45178","db":"test","resource":"","details":"d755296"},{"timestamp":"1702548856938201478","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:45166","db":"test","resource":"","details":"d380324"},{"timestamp":"1702548856937740618","cluster_id":"8468922059162439502","user":"root","operation":"createTable","client_add":"173.50.0.7:50288","db":"test","resource":"","details":"d5266"}]}`