import java.sql.*;
public class Main {
public static void main(String[] args) throws SQLException {
String ClassName =
"com.mysql.jdbc.Driver";
String url =
"jdbc:mysql://localhost:3306/test";
String userName =
"root";
String password =
"root";
Connection connect =
null;
Savepoint sp =
null;
PreparedStatement statement1 =
null;
PreparedStatement statement2 =
null;
try {
connect.setAutoCommit(
true);
Class.forName(ClassName);
connect = DriverManager.getConnection(url, userName, password);
System.
out.println(
"222Success connent the Mysql server");
String sql =
"select * from user";
String sql2 =
"update user set password = '8888' where name = '呵呵'";
statement1 = connect.prepareStatement(sql);
sp = connect.setSavepoint(
"111");
statement2 = connect.prepareStatement(sql2);
statement1.executeQuery();
statement2.executeUpdate();
}
catch (ClassNotFoundException e) {
System.
out.println(
"Error loading Mysql Driver");
e.printStackTrace();
}
catch (SQLException e) {
connect.rollback();
connect.rollback(sp);
e.printStackTrace();
}
finally {
statement1.close();
statement2.close();
connect.close();
}
}
}