RxJava 批量插入-JDBC
Batch insertion in RxJava-JDBC
我有一个要插入数据库的数据列表。我当前使用 RxJava-JDBC 的解决方案类似于以下代码片段:
String sql_batch_insert = "insert into ... values(?, ?);
Observable<List<..>> data = ...;
data.flatMap(list ->
Observable.from(list)
.flatMap(pair ->
database.update(sql_batch_insert)
.parameters(table_name, pair.getKey(), pair.getValue())
.count()
)
)
如何进行批量插入?
从 Github 项目中得到答案:我可以对从 insert(...) 方法返回的 Builder 对象调用 batchSize(int)
我有一个要插入数据库的数据列表。我当前使用 RxJava-JDBC 的解决方案类似于以下代码片段:
String sql_batch_insert = "insert into ... values(?, ?);
Observable<List<..>> data = ...;
data.flatMap(list ->
Observable.from(list)
.flatMap(pair ->
database.update(sql_batch_insert)
.parameters(table_name, pair.getKey(), pair.getValue())
.count()
)
)
如何进行批量插入?
从 Github 项目中得到答案:我可以对从 insert(...) 方法返回的 Builder 对象调用 batchSize(int)