jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(backend/db): fixed bug (index row size exceeds maximum) by adding left() func in sql requests

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2022-06-17 14:48:06 +02:00 • committed by rjshrjndrn
parent b993b1fefa
commit 1bf1999f65
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
backend/pkg/db/postgres/messages-common.go
View file

@ -115,7 +115,7 @@ func (conn *Conn) InsertRequest(sessionID uint64, timestamp uint64, index uint64
INSERT INTO events_common.requests (
session_id, timestamp, seq_index, url, duration, success
) VALUES (
$1, $2, $3, $4, $5, $6
$1, $2, $3, left($4, 2700), $5, $6
)`
conn.batchQueue(sessionID, sqlRequest, sessionID, timestamp, getSqIdx(index), url, duration, success)
@ -129,7 +129,7 @@ func (conn *Conn) InsertCustomEvent(sessionID uint64, timestamp uint64, index ui
INSERT INTO events_common.customs (
session_id, timestamp, seq_index, name, payload
) VALUES (
$1, $2, $3, $4, $5
$1, $2, $3, left($4, 2700), $5
)`
conn.batchQueue(sessionID, sqlRequest, sessionID, timestamp, getSqIdx(index), name, payload)
@ -222,7 +222,7 @@ func (conn *Conn) InsertIssueEvent(sessionID uint64, projectID uint32, e *messag
INSERT INTO events_common.customs
(session_id, seq_index, timestamp, name, payload, level)
VALUES
($1, $2, $3, $4, $5, 'error')
($1, $2, $3, left($4, 2700), $5, 'error')
`,
sessionID, getSqIdx(e.MessageID), e.Timestamp, e.ContextString, e.Payload,
); err != nil {

2
backend/pkg/db/postgres/messages-web-stats.go
View file

@ -57,7 +57,7 @@ func (conn *Conn) InsertWebStatsResourceEvent(sessionID uint64, e *ResourceEvent
) VALUES (
$1, $2, $3,
$4,
$5, $6, $7,
left($5, 2700), $6, $7,
$8, $9,
NULLIF($10, '')::events.resource_method,
NULLIF($11, 0), NULLIF($12, 0), NULLIF($13, 0), NULLIF($14, 0), NULLIF($15, 0)

4
backend/pkg/db/postgres/messages-web.go
View file

@ -229,7 +229,7 @@ func (conn *Conn) InsertWebFetchEvent(sessionID uint64, savePayload bool, e *Fet
duration, success
) VALUES (
$1, $2, $3,
$4, $5, $6, $7,
left($4, 2700), $5, $6, $7,
$8, $9, $10::smallint, NULLIF($11, '')::http_method,
$12, $13
) ON CONFLICT DO NOTHING`
@ -261,7 +261,7 @@ func (conn *Conn) InsertWebGraphQLEvent(sessionID uint64, savePayload bool, e *G
request_body, response_body
) VALUES (
$1, $2, $3,
$4,
left($4, 2700),
$5, $6
) ON CONFLICT DO NOTHING`
conn.batchQueue(sessionID, sqlRequest, sessionID, e.Timestamp, e.MessageID,