Fix loadFromCSV

MIYASHITA, Akihiro · MIYASHITA, Akihiro · commit ffcc9eb14e73 · 2024-08-06T19:08:12.000+09:00
diff --git a/lib/connection.js b/lib/connection.js
@@ -597,7 +597,7 @@ class Connection {
 		const rs = await Promise.all(
 			bulks.map(bulk => this._conn.insert(bulk).into(table))
 		);
-		return flatten(rs);
+		return rs.flatMap((r) => this._cassette.rows(r));
 	}
 
 	/**

Original file line number	Diff line number	Diff line change
`@@ -597,7 +597,7 @@ class Connection {`
`597`	`597`	`const rs = await Promise.all(`
`598`	`598`	`bulks.map(bulk => this._conn.insert(bulk).into(table))`
`599`	`599`	`);`
`600`		`- return flatten(rs);`
	`600`	`+ return rs.flatMap((r) => this._cassette.rows(r));`
`601`	`601`	`}`
`602`	`602`
`603`	`603`	`/**`