From 0b523364f31ab2fd4a08fc45883c7d13f22362a7 Mon Sep 17 00:00:00 2001 From: James Cor Date: Fri, 17 Jan 2025 15:10:02 -0800 Subject: [PATCH] transactions for import --- go/libraries/doltcore/mvdata/engine_table_writer.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/go/libraries/doltcore/mvdata/engine_table_writer.go b/go/libraries/doltcore/mvdata/engine_table_writer.go index dc91cac6e7a..914a215629f 100644 --- a/go/libraries/doltcore/mvdata/engine_table_writer.go +++ b/go/libraries/doltcore/mvdata/engine_table_writer.go @@ -187,8 +187,13 @@ func (s *SqlEngineTableWriter) WriteRows(ctx context.Context, inputChannel chan } }() - line := 1 + // If there were create table statements, they are automatically committed, so we need to start a new transaction + _, _, _, err = s.se.Query(s.sqlCtx, "START TRANSACTION") + if err != nil { + return err + } + line := 1 for { if s.statsCB != nil && atomic.LoadInt32(&s.statOps) >= tableWriterStatUpdateRate { atomic.StoreInt32(&s.statOps, 0)