dbsql2000.java

基于netbeans的java桌面应用程序合集

/*
 * DBSQL2000.java
 *
 * Created on 2007年8月11日, 上午1:28
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package org.xifei;
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 xifei
 */
public class DBSQL2000 {
    
    
    private static java.sql.Connection conn = null;
    private String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver" ;
    private String connString;
    
    public DBSQL2000(String HostIP,String dBName,String userName,String passWord) {
        if (conn == null) { //如果未边连接，就建立连接
            try {
                Class.forName(driver).newInstance();//注册SQL Server2000  JDBC
                
                connString = "jdbc:microsoft:sqlserver://"+HostIP+":1433;DatabaseName="+dBName;//此处用运了1433作为默认端口
                System.out.println("connString="+connString.toString());//示意连接串，包括driver,DBQ(数据库所放的位置，及数据库名）
                conn = DriverManager.getConnection(connString, userName, passWord);//建立连接
            } catch (Exception e) {
                System.out.println("Error Trace in getConnection() : " +
                        e.getMessage());//获得异常信息
            }
        }
    }
    
    public void doAddAndDelAndUpdate(String sql){//处理添加、删除、更新数据库数据的方法
        try {
            if(conn==null)return ;
            Statement stm=conn.createStatement();//利用对象实例化时创建的连接，再建一声名
            stm.executeUpdate(sql);//利用声名，执行SQL语句
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    public Vector doQuery(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 doTableHead(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 void closeAccessConnection() {//定义关闭连接的方法
        try {
            if (conn != null)
                conn.close();
            conn = null;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
}