哪位大哥能帮在下写一个完整的JDBC数据库操作类？过年了，帮帮忙，我实在是没米了。。。

Question

package smsadminj;import java.io.*;
import java.sql.*;
import java.util.*;public class DbConn
    implements Serializable {
  Connection conn = null;
  Statement stmt = null;
  ResultSet rs = null;
  public DbConn() {
  }  public Connection getConnection() {//连接ORACLE数据库
    if (conn == null) {
      try {        String fileName = this.getClass().getClassLoader().getResource("").
            getPath() +
            "config.properties";
        fileName = java.net.URLDecoder.decode(fileName, "gb2312");
        System.out.println("DbConn getConnection fileName:" + fileName);
        Properties p = new Properties();
        InputStream is = new FileInputStream(fileName);
        p.load(is);
        String url = p.getProperty("DB_Url");
        String user = p.getProperty("DB_User");
        String password = p.getProperty("DB_Password");
        is.close();        /* String url = "jdbc:oracle:thin:@192.168.1.33:1521:orcl";
         String user = "coverm";//"adatmobile";
         String password = "coverm";//"mobile";
         */
        Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();        conn = java.sql.DriverManager.getConnection(url, user, password);
        System.out.println(url + user + password);
      }
      catch (Exception e) {
        System.out.println("Conn-->getConnection出错:" + e.toString());
      }
    }
    return conn;
  }  public void closeConnection() {//关闭数据库连接
    try {
      if (conn != null) {
        if (stmt != null) {
          stmt.close();
          stmt = null;
        }
        conn.close();
        conn = null;
      }
    }
    catch (Exception e) {
      System.err.println(e);
    }
  }  public ResultSet executeQuery(String sql, boolean pre) {//查询数据库
    rs = null;
    try {
      Connection conn1 = this.getConnection();
      if (conn1 == null) {
        System.out.println("conn is null!");
      }
      else if (pre == true) {
        stmt = conn1.createStatement(1004, 1007);
        rs = stmt.executeQuery(sql);
      }
      else if (pre == false) {
        stmt = conn1.createStatement();
        rs = stmt.executeQuery(sql);
      }
    }
    catch (SQLException e) {
      System.err.println("Conn-->executeQuery出错：" + e.getMessage());
    }
    return rs;
  }  public boolean executeUpdate(String sql) {//增，删，改-数据库
    boolean bupdate = false;
    try {
      Connection conn1 = this.getConnection();
      if (conn1 != null) {
        stmt = conn1.createStatement();
        int rowCount = stmt.executeUpdate(sql);
        bupdate = true;
      }
    }
    catch (SQLException e) {
      System.err.println(e.getMessage());
    }
    return bupdate;
  }
}
我尽力了！

Answer 1

这是Oracle的数据库连接吧？楼主应该是想要SQL的吧，那我就写个SQL的
        Connection con=null;
        Statement st=null;
        ResultSet rs=null;
       
        try {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            con=DriverManager.getConnection("jdbc:odbc:LocalServer","sa","");
            if(con!=null)
            {
                System.out.println(loginname+"   "+pwd);
            }
           //查询
            String strSQL="select * from jobs";
            rs=st.executeQuery(strSQL);
            while(rs.next())
            {
              System.out.println(rs.getString(1));
                       ...           
            }

Answer 2

package com.qspower.bb.dao;import java.sql.*;public class DBAccess {
//建立连接数据库对象
Connection conn = null;
//建立语句对象
Statement stmt = null;
//载入数据库驱动
String sDriver = "orj.git.mm.mysql.Driver";
//数据库路径
String sDurl = "jdbc:mysql://localhost/powa?user=root&password=1234&useUnicode=true&characterEncoding=ISO-8859-1";
//构造函数程序开始就执行
public DBAccess() {
try {
//载入数据库驱动
Class.forName(sDriver);
//建立数据库连接
conn = DriverManager.getConnection(sDurl);
//建立语句对象
stmt = conn.createStatement();
System.out.println("连接成功");
} catch (Exception e) {
e.printStackTrace();
System.out.println("连接失败");
}
} //处理查询 返回一个记录集rs
public ResultSet sendQuery(String sql) {
ResultSet rs = null;
try {
rs = stmt.executeQuery(sql);
return rs;
} catch (SQLException e) {
e.printStackTrace();
return null;
}
} //处理数据更新
public void sendUpdate(String sql) {
try {
stmt.executeUpdate(sql);
} catch (SQLException e) {
e.printStackTrace();
}
} //关闭数据库连接
public void close_conn() {
try {
//关闭连接
conn.close();
System.out.println("数据库关闭成功");
} catch (Exception e) {
System.out.println("数据库关闭失败");
System.out.println(e.getMessage());
}
} public static void main(String arg[]) {
DBAccess db = new DBAccess();
String sql = "insert into student values()";
db.sendUpdate(sql);
}
}

Answer 3

JDBC连接数据库有很多写法,实质相同.baidu搜很多