首页 > 代码库 > JdbcTemplate使用事务
JdbcTemplate使用事务
public int excuteTrac() { int temp = 0; // 批插入 String sql1[] = new String[4]; //向第一个表插入的语句 sql1[0] = "insert into usermbo(USERNAME,age,PASSWORD) values(‘ 23 ‘,‘3‘,‘45‘)"; sql1[1] = "insert into usermbo(USERNAME,age,PASSWORD) values(‘22 ‘,‘22‘,‘22‘)"; sql1[2] = "insert into usermbo(USERNAME,age,PASSWORD) values(‘ 44 ‘,‘44‘,‘4‘)"; sql1[3] = "insert into usermbo(USERNAME,age,PASSWORD) values(‘ 55 ‘,‘55‘,‘55‘)"; String[] sql2 = new String[3]; //向第二个表插入的语句 sql2[0] = "insert into address(NO,NAME) values(‘21‘,‘33‘)"; // 此条数据是错误数据 插入会出现异常 sql2[1] = "insert into address(NO,NAME) values(‘ee‘,‘44‘)"; sql2[2] = "insert into address(NO,NAME) values(‘44‘,‘44‘)"; DefaultTransactionDefinition def = new DefaultTransactionDefinition(); DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(jdbcTemplate.getDataSource()); TransactionStatus status = transactionManager.getTransaction(def); try { int[] a = jdbcTemplate.batchUpdate(sql1); int[] b = jdbcTemplate.batchUpdate(sql2); for (int x : a) { System.out.println(x); } for (int x : b) { System.out.println(x); } } catch (Exception ex) { System.out.println("出现事务异常"); // transactionManager.rollback(status); temp = -1; } finally { transactionManager.commit(status); } return temp; }
JdbcTemplate使用事务
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。