Ajax实现xml文件数据插入数据库（三）---javabean实现数据库插入

[java]  view plain  copy package DbUtil;   import java.sql.Connection;   import java.sql.DriverManager;   import java.sql.PreparedStatement;   import java.sql.ResultSet;   import java.sql.SQLException;   import java.sql.Statement;      /**   * 封装数据库常用操作   * @author changshou   *   */   public class DbUtil {           //取得数据库连接       public static Connection getConnection(){           Connection conn = null;           try {               Class.forName("oracle.jdbc.driver.OracleDriver");               String url = "jdbc:oracle:thin:@localhost:1521:ORCL";               String username = "drp1";               String password = "drp1";               conn = DriverManager.getConnection(url, username, password);           } catch (ClassNotFoundException e) {               // TODO Auto-generated catch block               e.printStackTrace();           } catch (SQLException e) {               // TODO Auto-generated catch block               e.printStackTrace();           }           return conn;       }              //关闭连接       public static void close(Connection conn){                 if(conn != null){                try {                    conn.close();               } catch (SQLException e) {                    // TODO Auto-generated catch block                   e.printStackTrace();               }           }        }              //关闭PreparedStatement和Statement       public static void close(PreparedStatement pstmt){            if(pstmt != null){               try {                   pstmt.close();               } catch (SQLException e) {                    // TODO Auto-generated catch block                   e.printStackTrace();                }           }       }              //关闭Statement       public static void close(Statement stmt){            if(stmt != null){               try {                   stmt.close();               } catch (SQLException e) {                   // TODO Auto-generated catch block                   e.printStackTrace();               }           }       }              //关闭ResultSet       public static void close(ResultSet rs){           if(rs != null){               try {                   rs.close();               } catch (SQLException e) {                    // TODO Auto-generated catch block                   e.printStackTrace();               }           }                  }       /**        * 手动开启事务，不让事务自动提交        * @param conn        */       public static void beginTransaction(Connection conn){           try{               if(conn != null){                   if(conn.getAutoCommit()){                       conn.setAutoCommit(false);//手动提交                   }               }                          }catch(SQLException e){                          }       }              /**        * 提交事务        * @param conn       */       public static void commitTransaction(Connection conn){           try{               if(conn != null){                   if(!conn.getAutoCommit()){                       conn.commit();                   }               }                          }catch(SQLException e){                          }       }              /**       * 回滚事务       * @param conn       */       public static void rollbackTransaction(Connection conn){           try{               if(conn != null){                   if(!conn.getAutoCommit()){                       conn.rollback();                   }               }                          }catch(SQLException e){                          }       }              public static void reset(Connection conn){           try{               if(conn != null){                   if(conn.getAutoCommit()){                       conn.setAutoCommit(false);                   }else{                       conn.setAutoCommit(true);                   }               }                          }catch(SQLException e){                          }       }   }   下面的代码将真正执行数据的插入操作，注意在执行代码前需引入相关jar包，如jdbc驱动等。否则在执行的过程中会报错。

[java]  view plain  copy package UserManager;   import java.sql.Connection;   import java.sql.PreparedStatement;      import com.sun.org.apache.bcel.internal.generic.RETURN;      import DbUtil.*;   public class UserManager {              public void insertUser(String userId,String userName,String userRoot){           //执行插入的sql语句           String sql = "INSERT INTO T_TEST1 (USERUD,USERNAME,USERROOT) VALUES (?,?,?)";           Connection conn = null;           PreparedStatement pstmt = null;           try{               //得到数据库连接               conn = DbUtil.getConnection();               pstmt = conn.prepareStatement(sql);               //给占位符赋值               pstmt.setString(1,userId);               pstmt.setString(2, userName);               pstmt.setString(3, userRoot);               //执行插入语句               pstmt.executeUpdate();           }catch(Exception e){               e.printStackTrace();                          }finally{               //关闭相关资源               DbUtil.close(pstmt);               DbUtil.close(conn);           }       }   }