diff --git a/go/cmd/dolt/commands/sql.go b/go/cmd/dolt/commands/sql.go
index b30f3a8f64..b355e002b8 100755
--- a/go/cmd/dolt/commands/sql.go
+++ b/go/cmd/dolt/commands/sql.go
@@ -165,6 +165,9 @@ func scanStatements(data []byte, atEOF bool) (advance int, token []byte, err err
 // runBatchMode processes queries until EOF and returns the resulting root value
 func runBatchMode(ctx context.Context, dEnv *env.DoltEnv, root *doltdb.RootValue) (*doltdb.RootValue, error) {
 	scanner := bufio.NewScanner(os.Stdin)
+	const maxCapacity = 512 * 1024
+	buf := make([]byte, maxCapacity)
+	scanner.Buffer(buf, maxCapacity)
 	scanner.Split(scanStatements)
 
 	batcher := dsql.NewSqlBatcher(dEnv.DoltDB, root)