duckdb: increase default max_line_size [nt]

flarco · Oct 24, 2023 · 5e477b3 · 5e477b3
1 parent ce81e55
commit 5e477b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/database/database_duckdb.go b/database/database_duckdb.go
@@ -669,7 +669,7 @@ func (conn *DuckDbConn) BulkImportStream(tableFName string, ds *iop.Datastream)
 		})
 
 		sqlLines := []string{
-			g.F(`insert into %s (%s) select * from read_csv('%s', delim=',', header=True, columns=%s);`, table.FDQN(), strings.Join(columnNames, ", "), csvPath, conn.generateCsvColumns(ds.Columns)),
+			g.F(`insert into %s (%s) select * from read_csv('%s', delim=',', header=True, columns=%s, max_line_size=134217728);`, table.FDQN(), strings.Join(columnNames, ", "), csvPath, conn.generateCsvColumns(ds.Columns)),
 		}
 
 		var out []byte