|
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class MainClass {
public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
String url = "jdbc:mysql://localhost/chapter04_jdbc21";
connection = DriverManager.getConnection(url, "username", "password");
statement = connection.createStatement();
String update1 = "UPDATE employees SET email = 'a@a.com' WHERE email = 'a@b.com'";
statement.addBatch(update1);
String update2 = "UPDATE employees SET email = 'b@b.com' WHERE email = 'b@c.com'";
statement.addBatch(update2);
String update3 = "UPDATE employees SET email = 'c@c.com' WHERE email = 'c@d.com'";
statement.addBatch(update3);
statement.executeBatch();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
} // nothing we can do
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
} // nothing we can do
}
}
}
}
|
