package com.tool;

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

//這是一個(gè)工具類實(shí)現(xiàn)與數(shù)據(jù)庫(kù)的連接
public class JDBConnection {

//String sd="com.microsoft.sqlserver.jdbc.SQLServerDriver";
	String sd="net.sourceforge.jtds.jdbc.Driver";
 // String sd = "sun.jdbc.odbc.JdbcOdbcDriver";
 //String sc = "jdbc:odbc:db_Client";
//String sc="jdbc:sqlserver://127.0.0.1:1433/db_Client";
String sc="jdbc:jtds:sqlserver://localhost:1433/db_Client;TDS=8.0";
 ResultSet rs = null;
 Connection conect = null;
 public JDBConnection() {
     try {
     Class.forName(sd).newInstance();

   }
   catch (java.lang.ClassNotFoundException e) {
     System.err.println(e.getMessage());
   } catch (InstantiationException e) {
	// TODO Auto-generated catch block
	e.printStackTrace();
} catch (IllegalAccessException e) {
	// TODO Auto-generated catch block
	e.printStackTrace();
} 
 }

 public ResultSet executeQuery(String sql) {
   try {
	   System.out.println(conect);
	   System.out.println("rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr");
     conect = DriverManager.getConnection(sc,"sa","");
     System.out.println(conect);
     Statement stmt = conect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                             ResultSet.CONCUR_READ_ONLY);
     rs = stmt.executeQuery(sql);
     System.out.println("rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr");
     System.out.println(rs);
   }
   catch (SQLException ex) {
     System.err.println(ex.getMessage());
   }
   return rs;
 }

 public int executeUpdate(String sql) {
   int result = 0;
   try {
     conect = DriverManager.getConnection(sc,"sa","");
     Statement stmt = conect.createStatement();
     result = stmt.executeUpdate(sql);
   }
   catch (SQLException er) {
     System.err.println(er.getMessage());
   }
   return result;
 }

 public void close() {
   try {
     if (conect != null) {
       conect.close();
     }
   }
   catch (Exception e) {
     System.out.println(e);
   }
 }


  //設(shè)置提交
  public void setAutoCommit(boolean flag) {
    try {
      conect.setAutoCommit(flag);
    }
    catch (Exception exception) {
      System.out.println("Exception in set autoCommit :" + exception.getMessage());
    }
  }

  //執(zhí)行提交
  public void commit() {
    try {
      conect.commit();
    }
    catch (Exception exception) {
      System.out.println("Exception in commit :" + exception.getMessage());
    }
  }

  //執(zhí)行回滾
  public void rollback() {
    try {
      conect.rollback();
    }
    catch (Exception exception) {
      System.out.println("Exception in rollback :" + exception.getMessage());
    }
  }

  //將sql語(yǔ)句中的？號(hào)轉(zhuǎn)為相應(yīng)的參數(shù) ，其中參數(shù)為字符串型的
  public String editSqlCode(String sql, String str) {

    try {
      // 截取從0到第一個(gè)問(wèn)號(hào)的字符串加參數(shù)str，然后在加上第一問(wèn)號(hào)以后的字符串
      sql = sql.substring(0, sql.indexOf("?")) + str +
          sql.substring(sql.indexOf("?") + 1);
    }
    catch (Exception e) {
      System.out.println(e.getMessage());
    }
    return sql;
  }

  //將sql語(yǔ)句中的？號(hào)轉(zhuǎn)為相應(yīng)的參數(shù) ，其中參數(shù)為長(zhǎng)整型的
  public String editSqlCode(String sql, Integer str) {

    try {
      sql = sql.substring(0, sql.indexOf("?")) + str +
          sql.substring(sql.indexOf("?") + 1);

    }
    catch (Exception e) {
      System.out.println(e.getMessage());
    }
    return sql;
  }

  //將sql語(yǔ)句中的？號(hào)轉(zhuǎn)為相應(yīng)的參數(shù) ，其中參數(shù)為整型的
  public String editSqlCode(String sql, int str) { //提取SQL語(yǔ)句，并把(int str)傳出來(lái)的值來(lái)代替？

    try {
      sql = sql.substring(0, sql.indexOf("?")) + str +
          sql.substring(sql.indexOf("?") + 1);
    }
    catch (Exception e) {
      System.out.println(e.getMessage());
    }
    return sql;
  }
  //將sql語(yǔ)句中的？號(hào)轉(zhuǎn)為相應(yīng)的參數(shù) ，其中參數(shù)為整型的
  public String editSqlCode(String sql, Float str) { //提取SQL語(yǔ)句，并把(Float str)傳出來(lái)的值來(lái)代替？

    try {
      sql = sql.substring(0, sql.indexOf("?")) + str +
          sql.substring(sql.indexOf("?") + 1);
    }
    catch (Exception e) {
      System.out.println(e.getMessage());
    }
    return sql;
  }


}