package com.mwq.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Vector;

public class BaseDao {

	// 查詢多個記錄
	protected Vector selectSomeNote(String sql) {
		Vector<Vector<Object>> vector = new Vector<Vector<Object>>();// 創建結果集向量
		Connection conn = JDBC.getConnection();// 獲得數據庫連接
		try {
			Statement stmt = conn.createStatement();// 創建連接狀態對象
			ResultSet rs = stmt.executeQuery(sql);// 執行SQL語句獲得查詢結果
			int columnCount = rs.getMetaData().getColumnCount();// 獲得查詢數據表的列數
			int row = 1;// 定義行序號
			while (rs.next()) {// 遍歷結果集
				Vector<Object> rowV = new Vector<Object>();// 創建行向量
				rowV.add(new Integer(row++));// 添加行序號
				for (int column = 1; column <= columnCount; column++) {
					rowV.add(rs.getObject(column));// 添加列值
				}
				vector.add(rowV);// 將行向量添加到結果集向量中
			}
			rs.close();// 關閉結果集對象
			stmt.close();// 關閉連接狀態對象
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return vector;// 返回結果集向量
	}

	// 查詢單個記錄
	protected Vector selectOnlyNote(String sql) {
		Vector<Object> vector = null;
		Connection conn = JDBC.getConnection();
		try {
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			int columnCount = rs.getMetaData().getColumnCount();
			while (rs.next()) {
				vector = new Vector<Object>();
				for (int column = 1; column <= columnCount; column++) {
					vector.add(rs.getObject(column));
				}
			}
			rs.close();
			stmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return vector;
	}

	// 查詢多個值
	protected Vector selectSomeValue(String sql) {
		Vector<Object> vector = new Vector<Object>();
		Connection conn = JDBC.getConnection();
		try {
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
				vector.add(rs.getObject(1));
			}
			rs.close();
			stmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return vector;
	}

	// 查詢單個值
	protected Object selectOnlyValue(String sql) {
		Object value = null;
		Connection conn = JDBC.getConnection();
		try {
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
				value = rs.getObject(1);
			}
			rs.close();
			stmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return value;
	}

	// 插入、修改、刪除記錄
	public boolean longHaul(String sql) {
		boolean isLongHaul = true;// 默認持久化成功
		Connection conn = JDBC.getConnection();// 獲得數據庫連接
		try {
			conn.setAutoCommit(false);// 設置為手動提交
			Statement stmt = conn.createStatement();// 創建連接狀態對象
			stmt.executeUpdate(sql);// 執行SQL語句
			stmt.close();// 關閉連接狀態對象
			conn.commit();// 提交持久化
		} catch (SQLException e) {
			isLongHaul = false;// 持久化失敗
			try {
				conn.rollback();// 回滾
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			e.printStackTrace();
		}
		return isLongHaul;// 返回持久化結果
	}
	public static void main(String[] args) {
		BaseDao d=new BaseDao();
		d.longHaul("delete from tb_order_item");
		d.longHaul("delete from tb_order_form");
		d.longHaul("delete from tb_user");
	}
}