jdbconnection.java~2~

《struts应用开发完全手册》中的源代码及安装指导

package com.dao;

import java.sql.*;

public class JDBConnection {
    private final String dbDriver = "net.sourceforge.jtds.jdbc.Driver"; //加载数据库驱动
    private final String url = "jdbc:jtds:sqlserver://localhost:1433/db_upDownLoad";
    private final String userName = "sa";
    private final String passWord = "";
    private Connection connection = null;
    private Statement strament = null;
    private ResultSet rs = null;

//加载数据库驱动程序
    public void DataBaseConnection() {
        try {
            Class.forName(dbDriver).newInstance();
        } catch (Exception ex) {
            System.out.println("不能加载驱动");
        }

    }

//取得数据库的连接
    public boolean creatConnect() {
        try {
            connection = DriverManager.getConnection(url, userName, passWord);
        } catch (SQLException ex) {
            System.out.println("不能取得数据库的连接");
        }
        return true;
    }

    //进行数据库查询操作
    public ResultSet executeQuery(String sql) {
        if (connection == null) {
            creatConnect();
        }
        try {
            strament = connection.createStatement();
            rs = strament.executeQuery(sql);
        } catch (SQLException ex) {
            System.out.println("进行数据库查询操作不能成功");

        }
        return rs;
    }

    //进行数据库的增、删除、更新操作
    public boolean executeUpdate(String sql) {
        if (connection == null) {
            creatConnect();
        }
        try {
            strament = connection.createStatement();
            int iCount = strament.executeUpdate(sql);
            System.out.println("操作成功；所影响的记录数为" + String.valueOf(iCount));
        } catch (SQLException ex) {
            System.out.println("进行数据库的增、删除、更新操作不能成功");
        }
        return true;
    }

//对数据库的提交
    public boolean commit() {
        try {
            connection.commit();
        } catch (SQLException ex) {
            System.out.println("对数据库的提交操作不能成功");
        }

        return true;
    }

    //关闭数据库的连接
    public void closeDBConnect() {
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException ex) {
                System.out.println("关闭数据库的连接操作不能成功");
            }

        }
    }
}