diff --git a/go/libraries/doltcore/sqle/database_provider.go b/go/libraries/doltcore/sqle/database_provider.go index bda772aad4..f9dcb0b7cd 100644 --- a/go/libraries/doltcore/sqle/database_provider.go +++ b/go/libraries/doltcore/sqle/database_provider.go @@ -420,11 +420,13 @@ func (p *DoltDatabaseProvider) CreateDatabase(ctx *sql.Context, name string) err func commitTransaction(ctx *sql.Context, dSess *dsess.DoltSession, rsc *doltdb.ReplicationStatusController) error { currentTx := ctx.GetTransaction() - - err := dSess.CommitTransaction(ctx, currentTx) - if err != nil { - return err + if currentTx != nil { + err := dSess.CommitTransaction(ctx, currentTx) + if err != nil { + return err + } } + newTx, err := dSess.StartTransaction(ctx, sql.ReadWrite) if err != nil { return err