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("關閉數據庫的連接操作不能成功");
     }

   }
 }
}