package com.tool;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBConnection {

	private final String DRIVER = "net.sourceforge.jtds.jdbc.Driver"; // 連接sql數據庫的方法

	private final String URL = "jdbc:jtds:sqlserver://localhost:1433/db_sell";

	private final String USERNAME = "sa";

	private final String PASSWORD = "";

	private Connection conn = null;

	public JDBConnection() {
		try {
			Class.forName(DRIVER).newInstance(); // 加載數據庫驅動
		} catch (Exception ex) {
			System.out.println("加載數據庫驅動失敗!");
		}
	}

	public boolean creatConnection() {// 用來創建數據庫連接
		boolean isCreated = true;// 默認創建成功
		try {
			conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);// 創建數據庫連接
		} catch (SQLException e) {
			isCreated = false;// 創建失敗
		}
		return isCreated;// 返回創建情況
	}

	public boolean executeUpdate(String sql) {// 用來插入、修改和刪除記錄
		boolean isUpdate = true;// 默認執行成功
		if (conn == null)
			creatConnection();
		try {
			Statement stmt = conn.createStatement();
			stmt.executeUpdate(sql);
		} catch (SQLException e) {
			isUpdate = false;// 執行失敗
		}
		return isUpdate;// 返回執行情況
	}

	public ResultSet executeQuery(String sql) {// 用來查詢記錄
		ResultSet rs = null;
		if (conn == null)
			creatConnection();
		try {
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;// 返回查詢結果集
	}

	public void closeConnection() {// 用來關閉數據庫連接
		if (conn != null) {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				conn = null;
			}
		}
	}

}