handle default case in duckdb BulkImportFlow

slingdata-io · Dec 26, 2024 · d828f57 · d828f57
1 parent e30074b
commit d828f57
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/dbio/database/database_duckdb_unix.go b/core/dbio/database/database_duckdb_unix.go
@@ -23,9 +23,9 @@ func (conn *DuckDbConn) BulkImportFlow(tableFName string, df *iop.Dataflow) (cou
 	case "csv_files":
 		return conn.importViaTempCSVs(tableFName, df)
 	case "http_server":
-		fallthrough
-	default:
 		return conn.importViaHTTP(tableFName, df)
+	default:
+		return conn.importViaTempCSVs(tableFName, df)
 	}
 }
 

diff --git a/core/dbio/database/database_duckdb_windows.go b/core/dbio/database/database_duckdb_windows.go
@@ -11,8 +11,8 @@ func (conn *DuckDbConn) BulkImportFlow(tableFName string, df *iop.Dataflow) (cou
 	case "csv_files":
 		return conn.importViaTempCSVs(tableFName, df)
 	case "http_server":
-		fallthrough
-	default:
 		return conn.importViaHTTP(tableFName, df)
+	default:
+		return conn.importViaTempCSVs(tableFName, df)
 	}
 }