JDBConnection.java
上传用户:quasar007
上传日期:2022-08-11
资源大小:4067k
文件大小:4k
源码类别:

企业管理

开发平台:

Java

  1. package com.tool;
  2. import java.sql.DriverManager;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.sql.ResultSet;
  6. import java.sql.Statement;
  7. //这是一个工具类实现与数据库的连接
  8. public class JDBConnection {
  9.   String sd = "sun.jdbc.odbc.JdbcOdbcDriver";
  10.  String sc = "jdbc:odbc:db_Client";
  11.  ResultSet rs = null;
  12.  Connection conect = null;
  13.  public JDBConnection() {
  14.      try {
  15.      Class.forName(sd);
  16.    }
  17.    catch (java.lang.ClassNotFoundException e) {
  18.      System.err.println(e.getMessage());
  19.    }
  20.  }
  21.  public ResultSet executeQuery(String sql) {
  22.    try {
  23.      conect = DriverManager.getConnection(sc);
  24.      Statement stmt = conect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
  25.                                              ResultSet.CONCUR_READ_ONLY);
  26.      rs = stmt.executeQuery(sql);
  27.    }
  28.    catch (SQLException ex) {
  29.      System.err.println(ex.getMessage());
  30.    }
  31.    return rs;
  32.  }
  33.  public int executeUpdate(String sql) {
  34.    int result = 0;
  35.    try {
  36.      conect = DriverManager.getConnection(sc);
  37.      Statement stmt = conect.createStatement();
  38.      result = stmt.executeUpdate(sql);
  39.    }
  40.    catch (SQLException er) {
  41.      System.err.println(er.getMessage());
  42.    }
  43.    return result;
  44.  }
  45.  public void close() {
  46.    try {
  47.      if (conect != null) {
  48.        conect.close();
  49.      }
  50.    }
  51.    catch (Exception e) {
  52.      System.out.println(e);
  53.    }
  54.  }
  55.   //设置提交
  56.   public void setAutoCommit(boolean flag) {
  57.     try {
  58.       conect.setAutoCommit(flag);
  59.     }
  60.     catch (Exception exception) {
  61.       System.out.println("Exception in set autoCommit :" + exception.getMessage());
  62.     }
  63.   }
  64.   //执行提交
  65.   public void commit() {
  66.     try {
  67.       conect.commit();
  68.     }
  69.     catch (Exception exception) {
  70.       System.out.println("Exception in commit :" + exception.getMessage());
  71.     }
  72.   }
  73.   //执行回滚
  74.   public void rollback() {
  75.     try {
  76.       conect.rollback();
  77.     }
  78.     catch (Exception exception) {
  79.       System.out.println("Exception in rollback :" + exception.getMessage());
  80.     }
  81.   }
  82.   //将sql语句中的?号转为相应的参数 ,其中参数为字符串型的
  83.   public String editSqlCode(String sql, String str) {
  84.     try {
  85.       // 截取从0到第一个问号的字符串加参数str,然后在加上第一问号以后的字符串
  86.       sql = sql.substring(0, sql.indexOf("?")) + str +
  87.           sql.substring(sql.indexOf("?") + 1);
  88.     }
  89.     catch (Exception e) {
  90.       System.out.println(e.getMessage());
  91.     }
  92.     return sql;
  93.   }
  94.   //将sql语句中的?号转为相应的参数 ,其中参数为长整型的
  95.   public String editSqlCode(String sql, Integer str) {
  96.     try {
  97.       sql = sql.substring(0, sql.indexOf("?")) + str +
  98.           sql.substring(sql.indexOf("?") + 1);
  99.     }
  100.     catch (Exception e) {
  101.       System.out.println(e.getMessage());
  102.     }
  103.     return sql;
  104.   }
  105.   //将sql语句中的?号转为相应的参数 ,其中参数为整型的
  106.   public String editSqlCode(String sql, int str) { //提取SQL语句,并把(int str)传出来的值来代替?
  107.     try {
  108.       sql = sql.substring(0, sql.indexOf("?")) + str +
  109.           sql.substring(sql.indexOf("?") + 1);
  110.     }
  111.     catch (Exception e) {
  112.       System.out.println(e.getMessage());
  113.     }
  114.     return sql;
  115.   }
  116.   //将sql语句中的?号转为相应的参数 ,其中参数为整型的
  117.   public String editSqlCode(String sql, Float str) { //提取SQL语句,并把(Float str)传出来的值来代替?
  118.     try {
  119.       sql = sql.substring(0, sql.indexOf("?")) + str +
  120.           sql.substring(sql.indexOf("?") + 1);
  121.     }
  122.     catch (Exception e) {
  123.       System.out.println(e.getMessage());
  124.     }
  125.     return sql;
  126.   }
  127. }