From 9f4f661eef77246146e983cef1045d4edbd06696 Mon Sep 17 00:00:00 2001 From: "Mahlon E. Smith" Date: Mon, 12 Feb 2018 13:25:26 -0800 Subject: [PATCH] Wrap commits in a transaction. --- netdata_tsrelay.nim | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/netdata_tsrelay.nim b/netdata_tsrelay.nim index 65a4908..a48c953 100644 --- a/netdata_tsrelay.nim +++ b/netdata_tsrelay.nim @@ -129,10 +129,14 @@ proc process( client: Socket, db: DBConn ): void = return var samples = parse_data( raw_data ) + if samples.len == 0: return + + db.exec sql( "BEGIN" ) for timestamp, sample in samples: var host = sample[ "hostname" ].get_str sample.delete( "hostname" ) db.exec sql( INSERT_SQL ), timestamp, host, sample + db.exec sql( "COMMIT" ) proc serverloop: void = ## Open a database connection, bind to the listening socket,