jdbconnection.java~1~

销售管理系统 随着我国国民经济的持续发展

package com.tool;

import java.sql.*;

public class JDBConnection {
  private final String dbDriver = "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 con = null;

  public JDBConnection() {
    try {
      Class.forName(dbDriver).newInstance();
    }
    catch (Exception e) {
      System.out.println(e.getMessage());
      System.out.println("classForNameError!");
    }
  }

  public boolean creatConnection() {
    try {
      con = DriverManager.getConnection(url, userName, password);
      con.setAutoCommit(true);
    }
    catch (SQLException e) {
      System.out.println(e.getMessage());
      System.out.println("creatConnectionError!");
    }
    return true;
  }

  public boolean executeUpdate(String sql) {

    if (con == null) {
      creatConnection();
    }
    try {
      Statement stmt = con.createStatement();
      int iCount = stmt.executeUpdate(sql);
      System.out.println("操作成功，所影响的记录数为" + String.valueOf(iCount));
    }
    catch (SQLException e) {
      System.out.println(e.getMessage());
      System.out.println("executeUpdaterError!");
    }
    return true;
  }

  public ResultSet executeQuery(String sql) {
    ResultSet rs;
    try {
      if (con == null) {
        creatConnection();
      }
      Statement stmt = con.createStatement();
      try {
        rs = stmt.executeQuery(sql);
      }
      catch (SQLException e) {
        System.out.println(e.getMessage());
        return null;
      }
    }
    catch (SQLException e) {
      System.out.println(e.getMessage());
      System.out.println("executeQueryError!");
      return null;
    }
    return rs;
  }

  public boolean commit() {
    try {
      con.commit();
    }
    catch (SQLException e) {
      System.out.println(e.getMessage());
      System.out.println("commintError!");
    }
    return true;
  }


  public void closeDBConnection() {

    if (con != null) {
      try {
        con.close();
      }
      catch (SQLException e) {
        e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
        System.out.println("Failed to close connection!");
      }
      finally {
        con = null;
      }
    }
  }
}