package sqlitedb;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;

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

import business.BusinessLogic;

import common.ConfFiles;

/**
 * Operations on sqlite database.
 * Attention: Sqlite is coded by UTF-8 defaultly.
 * @author zkl
 */
public class DBwrapper {
	
	public static String SQLITEDBPATH;
	
	static {
		System.out.println("-------------------------------------");
		System.out.println("Read client conf file ...");
		String fileServerConf = ConfFiles.client_db_conf_file;
		try {
			FileReader fr = new FileReader(fileServerConf);
			BufferedReader br = new BufferedReader(fr);
			String line;
			while ((line = br.readLine()) != null) {
				if(line.trim().startsWith("#"))
					continue;
				int start = line.indexOf("=");
				if( start < 0)
					continue;
				int len = line.length();
				String name = line.substring(0, start);
				String value = line.substring(start+1, len);
				if (name.equalsIgnoreCase("dbpath")) {
					SQLITEDBPATH = value;
				}
				System.out.println(name + " " + value);
			}
		} catch (IOException ioe) {
			System.out.println("Read congig file error! " + ioe.getMessage());
		}
		System.out.println("Read client conf file finished.");
		System.out.println("-------------------------------------");
	}
	
	private String connStr; 
	private Connection conn;
	private Statement stat;
	private ResultSet rs;
	private String sqlStr;
	private int affectedRows; /* update sql operation */
	
	public DBwrapper()
	{
		connStr = "jdbc:sqlite:" + SQLITEDBPATH;
	}
	
	public DBwrapper(String dbPath)
	{
		connStr = "jdbc:sqlite:" + dbPath;
	}
	
	/**
	 * Connect to sqlite database.
	 * @return
	 *        true  -- sucessful.
	 *        false -- failed.
	 */
	public boolean open()
	{
		try {
			Class.forName("org.sqlite.JDBC");
			conn = DriverManager.getConnection(connStr);
			stat = conn.createStatement();
			System.out.println("Connect sqlite database successful!");
			return true;
		} catch (SQLException ex) {
			System.out.println("Connect sqlite database failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		} catch (ClassNotFoundException ex) {
			System.out.println("Connect sqlite database failed!");
			System.out.println("Exception: Message - " + ex.getMessage());
			return false;
		} catch (Exception ex) {
			System.out.println("Connect sqlite database failed!");
			System.out.println("Exception: Message - " + ex.getMessage());
			return false;
		}
	}
	
	/**
	 * Close the connection to sqlite database.
	 * @return
	 * 	      true  -- sucessful.
	 *        false -- failed.
	 */
	public boolean close() {
		try {
			stat.close();
			conn.close();
			System.out.println("Close connection successful!");
			return true;
		} catch (SQLException ex) {
			System.out.println("Close connection failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		} catch (Exception ex) {
			System.out.println("Execute update sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());
			return false;
		}
		
	}
	
	public void setSQL(String sqlStr)
	{
		this.sqlStr = sqlStr;
	}
	
	/**
	 * Execute update SQL.
	 * @return
	 * 	      true  -- sucessful.
	 *        false -- failed.
	 */
	public boolean execUpdateSQL()
	{
		try {
			stat.executeUpdate(sqlStr);
			affectedRows = stat.getUpdateCount(); //affected rows
			conn.commit();
			System.out.println("Execute update sql successful!");
			return true;
		} catch (SQLException ex) {
			System.out.println("Execute update sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		} catch (Exception ex) {
			System.out.println("Execute update sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());
			return false;
		}
	}
	
	/**
	 * Execute select SQL.
	 * @return
	 * 	      true  -- sucessful.
	 *        false -- failed.
	 */
	public boolean execQuerySQL()
	{
		if(sqlStr.isEmpty() || sqlStr == null) {
			System.out.println("SQL statement could not be null.");
			return false;
		}
		try {
			rs = stat.executeQuery(sqlStr);
			System.out.println("Execute select sql successful!");
			return true;
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		} catch (Exception ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());
			return false;
		}
	}
	
	public boolean commit() {
		try {
			conn.commit();
			return true;
		} catch (SQLException ex) {
			System.out.println("Commit failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		}
	}
	
	public Connection getConnection() {
		return conn;
	}
	
	public Statement getStatement() {
		return stat;
	}
	
	public ResultSet getResultSet() {
		return rs;
	}
	
	public int getAffectedRows() {	
		return affectedRows;
	}
	
	public boolean setAutoCommit(boolean autoCommit) {
		try {
			conn.setAutoCommit(autoCommit);
			return true;
		} catch (SQLException ex) {
			System.out.println("Commit failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
			return false;
		}
	}
	
	/**
	 * 
	 * @param sqlStr. SQL statement.
	 * @param op. operation, select, insert, update, delete
	 * @return
	 */
	public boolean execSQL(String sqlStr, String op)
	{
		if (!(op.equalsIgnoreCase("select") || op.equalsIgnoreCase("insert")
				|| op.equalsIgnoreCase("update") || op
				.equalsIgnoreCase("delete"))) {
			System.out.println("Operations of SQL only in 'select, insert, update, delete'.");
			return false;
		}
		
		this.sqlStr = sqlStr;
		
		if (op.equalsIgnoreCase("select")) {
			return execQuerySQL();
		} else {
			return execUpdateSQL();
		}
	}
	
	/**
	 * Execute multiple SQL statements, batch job.
	 * @return
	 */
	public boolean execBatch()
	{
		/*
		PreparedStatement prep = conn
				.prepareStatement("insert into people values (?, ?);");

		prep.setString(1, "Gandhi");
		prep.setString(2, "politics");
		prep.addBatch();
		prep.setString(1, "Turing");
		prep.setString(2, "computers");
		prep.addBatch();
		prep.setString(1, "Wittgenstein");
		prep.setString(2, "smartypants");
		prep.addBatch();

		conn.setAutoCommit(false);
		prep.executeBatch();
		conn.setAutoCommit(true);
		*/
		return false;
	}
	

	public static void main(String[] args) {

		String sqlStr = "";
		DBwrapper dbop = new DBwrapper();
		if (!dbop.open())
			return;
		Connection conn = dbop.getConnection();
		
		/*
		// drop table 
		sqlStr = "drop table if exists people";
		dbop.setSQL(sqlStr);
		dbop.setAutoCommit(false); // must set auto commit to "false" 
		if (!dbop.execUpdateSQL())
			return;
		dbop.setAutoCommit(true);
		// create table 
		sqlStr = "create table people (name primaey key, age int)";
		dbop.setSQL(sqlStr);
		dbop.setAutoCommit(false);
		if (!dbop.execUpdateSQL())
			return;
		dbop.setAutoCommit(true);
		*/
		
		/*
		// insert into table, batch job
		int updateCount = 0;
		try {
			PreparedStatement prep = conn
					.prepareStatement("insert into people values (?, ?);");
			String name = "zhankunlin";
			int age = 24;
			for(int i=0; i<5; i++) {
				prep.setString(1, name + i);
				prep.setInt(2, age+1);
				prep.addBatch();
			}
			dbop.setAutoCommit(false); // must set auto commit to "false" 
			prep.executeBatch();
			dbop.commit(); // you must commit
			updateCount = prep.getUpdateCount(); // ?
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());
		} 
		System.out.println(" Affected rows: " + updateCount );

		// insert one line into table 
		sqlStr = "insert into people (name, age) values ('zhaoyanhong', 25)";
		dbop.setSQL(sqlStr);
		//dbop.setAutoCommit(false);
		if (!dbop.execUpdateSQL())
			return;
		dbop.commit();
		updateCount = dbop.getAffectedRows();
		System.out.println(" Inserted rows: " + updateCount );
		//dbop.setAutoCommit(true);
		
		// insert one line into table 
		sqlStr = "update people set age = '24' where age = '25'";
		dbop.setSQL(sqlStr);
		//dbop.setAutoCommit(false);
		if (!dbop.execUpdateSQL())
			return;
		dbop.commit();
		updateCount = dbop.getAffectedRows();
		System.out.println(" Updated rows: " + updateCount );
		//dbop.setAutoCommit(true);
		*/
		
		/*
		sqlStr = "insert into GoodsUnit(GoodsUnit_ID, GoodsUnit) values (88, '好')";
		dbop.setSQL(sqlStr);
		dbop.setAutoCommit(false);
		if (!dbop.execUpdateSQL())
			return;
		dbop.commit();
		*/
		
		// query table
		sqlStr = "select GoodsUnit from GoodsUnit";
		dbop.setSQL(sqlStr);
		if (!dbop.execQuerySQL())
			return;
		ResultSet rs = dbop.getResultSet();
		int resultsCount = 0;
		try {
			while (rs.next()) {
				System.out.println(rs.getString("GoodsUnit"));
				++resultsCount;
			}
			rs.close();
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());

		} catch (Exception ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());

		}
		System.out.println("Line number: " + resultsCount);
		
		sqlStr = "select TaxCategory_Name from TaxCategory";
		dbop.setSQL(sqlStr);
		if (!dbop.execQuerySQL())
			return;
		rs = dbop.getResultSet();
		resultsCount = 0;
		try {
			while (rs.next()) {
				System.out.println(rs.getString("TaxCategory_Name"));
				++resultsCount;
			}
			rs.close();
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());

		} catch (Exception ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());

		}
		System.out.println("Line number: " + resultsCount);
		
		// 查詢客戶端當天已列印的發票
		String invoiceStatus = BusinessLogic.INVOICE_STATUS_PRINTED;
		sqlStr = "select Invoice_ID, InvoiceStatus, TerminalDevice_ID, Taxpayer_ID, Invoice_ActualReceiveMoney, Invoice_DateTime from Invoice ";
		sqlStr += " where InvoiceStatus = '" + invoiceStatus +"' ";
		sqlStr += " and date(Invoice_DateTime) = date('now') ";
		dbop.setSQL(sqlStr);
		if (!dbop.execQuerySQL())
			return;
		rs = dbop.getResultSet();
		resultsCount = 0;
		String invoiceInfo = "";
		try {
			while (rs.next()) {
				invoiceInfo += rs.getString("TerminalDevice_ID") +"|";
				//invoiceInfo += rs.getString("InvoiceStatus") +"|";
				invoiceInfo += rs.getString("Invoice_ID") +"|";
				invoiceInfo +=rs.getString("Taxpayer_ID") +"|";
				invoiceInfo +=rs.getString("Invoice_ActualReceiveMoney") +"|";
				invoiceInfo +=rs.getString("Invoice_DateTime") +"\n";
				++resultsCount;
			}
			rs.close();
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());

		} catch (Exception ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());

		}
		System.out.println("Line number: " + resultsCount);
		System.out.print(invoiceInfo);
		
		// 查詢客戶端當天列印的發票數量和交易總額
		invoiceStatus = BusinessLogic.INVOICE_STATUS_PRINTED;
		sqlStr = "select count(Invoice_ID) as invoiceCount, sum(Invoice_ActualReceiveMoney) as totalMoney from Invoice ";
		sqlStr += " where InvoiceStatus = '" + invoiceStatus +"' ";
		sqlStr += " and date(Invoice_DateTime) = date('now') ";
		dbop.setSQL(sqlStr);
		if (!dbop.execQuerySQL())
			return;
		rs = dbop.getResultSet();
		resultsCount = 0;
		int invoiceCount = 0;
		float totalMoney = 0;
		try {
			while (rs.next()) {
				invoiceCount = rs.getInt("invoiceCount");
				totalMoney = rs.getFloat("totalMoney");
				++resultsCount;
			}
			rs.close();
		} catch (SQLException ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Code - " + ex.getErrorCode()
					+ ", Message - " + ex.getMessage());

		} catch (Exception ex) {
			System.out.println("Execute select sql failed!");
			System.out.println("Exception: Message - " + ex.getMessage());

		}
		System.out.println(invoiceCount);
		System.out.println(totalMoney);
		if(invoiceCount == 0) {
			System.out.println("No invoice.");
		}
		if(invoiceCount == 4 && totalMoney == 8160) {
			System.out.println("OK.");
		}
		System.out.println("Line number: " + resultsCount);

		if (!dbop.close())
			return;
	}
}