java 操作mysql 事务处理

要进行实务操作 首先需要将mysql的操作表改成InnoDB引擎

取数据库连接：

/***

* 本地mysql服务器

* @return

*/

public static synchronized Connection getConFromLocal() {

Connection con = null;

String url = "jdbc:mysql://localhost:3306/123?zeroDateTimeBehavior=round&allowMultiQueries=true&useUnicode=true&characterEncoding=gbk;autoReconnect=true;failOverReadOnly=false;maxReconnects=10wait_timeout=31536000;interactive_timeout=31536000";

String userName = "******";

String password = "*****";

try {

Class.forName("com.mysql.jdbc.Driver");

con = DriverManager.getConnection(url, userName, password);

} catch (SQLException ex1) {

ex1.printStackTrace();

} catch (ClassNotFoundException ex) {

ex.printStackTrace();

}

return con;

}

调用本地数据库进行调度：

public static void srcl( ){

Connection con_copy = getConFromLocal();

Statement stmt_copy=getConFromRemote().createStatement();

con_copy.setAutoCommit(false);

for(int i=0;i<n;i++){

sql="";

stmt_copy.execute(sql);

}

try{

/***

* 事务提交

*/

con_copy.commit();

}catch (SQLException e) {

// TODO Auto-generated catch block

try {

/***

* 事务回滚

*/

con_copy.rollback();

} catch (SQLException e1) {

e1.printStackTrace();

}

e.printStackTrace();

}finally{

/***

* 事务处理

*/

try {

con_copy.setAutoCommit(true);

} catch (SQLException e) {

e.printStackTrace();

}

}

stmt_copy.close();

con_copy.close();

}