database.java~30~

我从网上下的,好像还行,和大家分享一下,

package atm;

import java.sql.*;
/**
 *
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2007</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

/**
 * 连接数据库的类
 */
public class Database {

        private Statement stmt=null;
        ResultSet rs=null;
        private Connection conn=null;
        String sql;
        String ip="127.0.0.1";
        String socket="1433";
        private void getIP(){
          if(LoginFrame.ip!=null&&LoginFrame.socket!=null){
            this.ip=LoginFrame.ip;
            this.socket=LoginFrame.socket;
          }
        }
        String url="jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=Data\\atm.mdb";
        /**
         * 打开数据库连接
         */
        public void OpenConn()throws Exception{
                try{
                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                        conn=DriverManager.getConnection(url,"user","123");
                }
                catch(Exception e){
                        System.err.println("OpenConn:"+e.getMessage());
                }
        }

        /**
         * 执行sql语句，返回结果集rs
         */
        public ResultSet executeQuery(String sql){
                stmt = null;
                rs=null;
                try{
                        stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
                        rs=stmt.executeQuery(sql);
                }
                catch(SQLException e){
                        System.err.println("executeQuery:"+e.getMessage());
                }
                return rs;
        }

        /**
         * 执行sql语句
         */
        public void executeUpdate(String sql){
                stmt=null;
                rs=null;
                try{
                        stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
                        stmt.executeQuery(sql);
                        conn.commit();
                }
                catch(SQLException e){
                        System.err.println("executeUpdate:"+e.getMessage());
                }
        }

        public void closeStmt(){
                try{
                        stmt.close();
                }
                catch(SQLException e){
                        System.err.println("closeStmt:"+e.getMessage());
                }
        }

        /**
         * 关闭数据库连接
         */
        public void closeConn(){
                try{
                        conn.close();
                }
                catch(SQLException ex){
                        System.err.println("userInfo.closeConn:"+ex.getMessage());
                }
        }

        /*
         *转换编码
         */
        public static String toGBK(String str){
                try {
                        if(str==null)
                                str = "";
                        else
                                str=new String(str.getBytes("ISO-8859-1"),"GBK");
                }
                catch (Exception e) {System.out.println(e);}

                return str;
        }
}