db.java

java netbeans 学习程序合集

/*
 * DB.java
 *
 * Created on 2007年12月20日, 下午6:23
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package org.Adam;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Vector;
/**
 *
 * @author Administrator
 */
public class DB {
    public java.sql.Connection conn = null;
    private String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver" ;    
    private String connString;
    Statement stat=null;
    ResultSet rs = null;
   public DB() {
        if (conn == null) { //如果未边连接，就建立连接
            try {
                //String dataBase="StudentInformation";
                 String userName="sa";
                   String passWord="";
                Class.forName(driver).newInstance();//注册SQL Server2000  JDBC
                connString = "jdbc:microsoft:sqlserver://localhost:1433;databaseName=StudentInformation";//此处用运了1433作为默认端口
                //System.out.println("connString="+connString.toString());//示意连接串，包括driver,DBQ(数据库所放的位置，及数据库名）
                conn = DriverManager.getConnection(connString, userName, passWord);//建立连接
                //System.out.println("ok");
            } catch (Exception e) {
               System.out.println("Error Trace in getConnection() : " + e.getMessage());//获得异常信息
            }
        }
    }
    /** Creates a new instance of DB */
    public void closeAccessConnection() {//定义关闭连接的方法
        try {
            if (conn != null)
                conn.close();
            conn = null;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
  public ResultSet SelectpassDb(String sql)
   {
       //String sql = "select password from userinfo where uid='"+uid+"'";
       try {
           stat = conn.createStatement();
           rs=stat.executeQuery(sql);


       } catch (SQLException ex) {
           System.out.println(ex.getMessage());
       }
       /*finally
       {
           try {
               //rs.close();
               //stat.close();
               //conn.close();
           } catch (SQLException ex1) {
               System.out.println(ex1.getMessage());
           }

       }*/
       return rs;


   }
    public void Adduser(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public void ChangePass(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public void Addclass(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public Vector doClassQuery(String sql){//处理查询数据库的方法，并反回一个集合类型的数据集
        Vector<Vector> vResult=new Vector();//定义一个能放多行（向量）数据的集合（Vector）
        try {
            if(conn==null)return null;
            Statement stm=conn.createStatement();
            ResultSet rs=stm.executeQuery(sql);
            ResultSetMetaData rmeta=rs.getMetaData();//得到结果数据集
            int numColumns=rmeta.getColumnCount();//通过结果数据集，获得列数
            while(rs.next()){//数据指针行方向变化，读多行数据
                Vector<String> hResult=new Vector();//定义一个能放一列的字符类型向量
                for(int i=0;i<numColumns;i++){//i作为列方向变化的指针，读一行数据
                    String sTemp=(String)rs.getString(i+1);//得到其中一行某一列的值
                    hResult.addElement(sTemp);   //把个个列值逐一加入定义好的向量中
                    
                }
                vResult.addElement(hResult);     //把整列数据加入到定义好的向量中
            }
            return vResult;
        } catch (SQLException ex) {
            ex.printStackTrace();
        }finally{
            return vResult;
        }
        
    }
    public Vector doClassTableHead(String sql){//处理查询数据库的方法，并反回一个集合类型的数据集
        Vector<String> hResult=new Vector();//定义一个能放一列的字符类型向量
        try {
            if(conn==null)return null;
            Statement stm=conn.createStatement();
            ResultSet rs=stm.executeQuery(sql);
            ResultSetMetaData rmeta=rs.getMetaData();//得到结果数据集
            int numColumns=rmeta.getColumnCount();//通过结果数据集，获得列数
            
            for(int i=0;i<numColumns;i++){//i作为列方向变化的指针，读一行数据
                String tempString=rmeta.getColumnName(i+1);
                hResult.addElement(tempString);   //把个个列值逐一加入定义好的向量中
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return hResult;
        
    }
    public ResultSet GetClassID(String sql)
   {
       //String sql = "select password from userinfo where uid='"+uid+"'";
       try {
           stat = conn.createStatement();
           rs=stat.executeQuery(sql);
       } catch (SQLException ex) {
           System.out.println(ex.getMessage());
       }    
       return rs;
   }
    public void Addstu(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public void AddMoneySet(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public ResultSet GetInformation(String sql)
   {
       //String sql = "select password from userinfo where uid='"+uid+"'";
       try {
           stat = conn.createStatement();
           rs=stat.executeQuery(sql);


       } catch (SQLException ex) {
           System.out.println(ex.getMessage());
       }
              return rs;


   }
    public void ChangeInformation(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public ResultSet GetClass(String sql)
   {
      try {
           stat = conn.createStatement();
           rs=stat.executeQuery(sql);
       } catch (SQLException ex) {
           System.out.println(ex.getMessage());
       }    
       return rs;
   }
}