package dao;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.SQLException;import util.DBHelper;import entity.User;public class Userdao { Connection conn = null; PreparedStatement ptmt = null; public int add() { int updateRows = 0; try { conn.setAutoCommit(false);// 开启jdbc事务管理 Connection conn = DBHelper.getConnection(); String sql = "insert into chaoshi_user(userCode,UserName)" + "value(?,?)"; ptmt = conn.prepareStatement(sql); ptmt.setString(1, "chentao"); ptmt.setString(2, "陈涛"); updateRows = ptmt.executeUpdate(); conn.commit();// 开始执行事务 if (updateRows > 0) { System.out.println("add success"); } else { System.out.println("add failure"); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); try { conn.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } finally { try { if(ptmt!=null){ ptmt.close();} if(conn!=null){ conn.close();} } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return updateRows; } public static void main(String[] args) { Userdao u = new Userdao(); u.add(); }}
添加回答
举报
0/150
提交
取消