jdbconnection.java~1~

《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/";
 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("关闭数据库的连接操作不能成功");
     }

   }
 }
}