イントロ
私が約束したように、私は完全な例をハックしました。MySQLを使用して、次のような3つのテーブルを作成しました。
CREATE TABLE `test{1,2,3}` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`data` varchar(255) NOT NULL UNIQUE,
PRIMARY KEY (`id`)
);
test2最初は単一の行が含まれます。
INSERT INTO `test2` (`data`) VALUES ('a');
（私は完全なコードをhttp://pastebin.comに投稿しました。）
次の例はいくつかのことを行います。
threads並行して実行されるジョブの数を3決定するセット。- 接続数を作成します
threads。
- すべてのテーブルのサンプルデータを吐き出します（デフォルトでは、データは
aすべてのテーブルのものです）。
threads実行するジョブの数を作成し、それらにデータをロードします。- スレッド
threadsの数でジョブを実行し、それらの完了を待ちます（成功したかどうか）。
- 例外が発生しなかった場合、すべての接続をコミットします。それ以外の場合は、それぞれをロールバックします。
- 接続を閉じます（ただし、これらは再利用できます）。
（でJava 7の自動リソース管理機能を使用したことに注意してくださいSQLTask.call()。）
論理
public static void main(String[] args) throws SQLException, InterruptedException {
int threads = 3;
List<Connection> connections = getConnections(threads);
Map<String, String> tableData = getTableData(threads);
List<SQLTask> tasks = getTasks(threads, connections);
setData(tableData, tasks);
try {
runTasks(tasks);
commitConnections(connections);
} catch (ExecutionException ex) {
rollbackConnections(connections);
} finally {
closeConnections(connections);
}
}
データ
private static Map<String, String> getTableData(int threads) {
Map<String, String> tableData = new HashMap<>();
for (int i = 1; i <= threads; i++)
tableData.put("test" + i, "a");
return tableData;
}
タスク
private static final class SQLTask implements Callable<Void> {
private final Connection connection;
private String data;
private String table;
public SQLTask(Connection connection) {
this.connection = connection;
}
public void setTable(String table) {
this.table = table;
}
public void setData(String data) {
this.data = data;
}
@Override
public Void call() throws SQLException {
try (Statement statement = connection.createStatement()) {
statement.executeUpdate(String.format(
"INSERT INTO `%s` (data) VALUES ('%s');", table, data));
}
return null;
}
}
private static List<SQLTask> getTasks(int threads, List<Connection> connections) {
List<SQLTask> tasks = new ArrayList<>();
for (int i = 0; i < threads; i++)
tasks.add(new SQLTask(connections.get(i)));
return tasks;
}
private static void setData(Map<String, String> tableData, List<SQLTask> tasks) {
Iterator<Entry<String, String>> i = tableData.entrySet().iterator();
Iterator<SQLTask> j = tasks.iterator();
while (i.hasNext()) {
Entry<String, String> entry = i.next();
SQLTask task = j.next();
task.setTable(entry.getKey());
task.setData(entry.getValue());
}
}
走る
private static void runTasks(List<SQLTask> tasks)
throws ExecutionException, InterruptedException {
ExecutorService executorService = Executors.newFixedThreadPool(tasks.size());
List<Future<Void>> futures = executorService.invokeAll(tasks);
executorService.shutdown();
for (Future<Void> future : futures)
future.get();
}
結果
によって返されるデフォルトのデータを考えるとgetTableData(...)
test1 -> `a`
test2 -> `a`
test3 -> `a`
また、2番目のジョブがtest2すでに含まれているa（そしてdata列が一意である）という事実は失敗し、例外をスローするため、すべての接続がロールバックされます。
sの代わりにasを返すbと、接続は安全にコミットされます。
これは、と同様に行うことができますLOAD DATA。
私の答えに対するOPの回答の後、私は彼女/彼がやりたいことを単純で明確な方法で行うことは不可能であることに気づきました。
基本的に問題は、コミットが成功した後、操作がアトミックであるため、コミットされたデータをロールバックできないことです。与えられたケースで複数のコミットが必要な場合、（すべてのトランザクションの）すべてのデータを追跡しない限り、すべてをロールバックすることはできません。何かが発生した場合、正常にコミットされたすべてのデータが削除されます。
コミットとロールバックの問題に関連する良い答えがあります。