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);  

        }  

    }  

}