JDBC连接常用数据库 基本的CURD

just  收藏于2022-04-19   转藏1次

[java]  view plain copy
  1. JDBC连接DB2  
  2.     private String className="com.ibm.db2.jdbc.net.DB2Driver";  
  3.     private String url="jdbc:db2://localhost:8080/lwc";  
  4. JDBC连接Microsoft SQLServer(microsoft)  
  5.     private String className="com.microsoft.jdbc.sqlserver.SQLServerDriver";  
  6.     private String url="jdbc:microsoft:sqlserver://  
  7.         localhost:1433;SelectMethod=Cursor;dataBaseName=lwc";  
  8. JDBC连接Sybase(jconn2.jar)  
  9.     private String className="com.sybase.jdbc2.jdbc.SybDriver";  
  10.     private String url="jdbc:sybase:Tds:localhost:2638";  
  11. JDBC连接MySQL(mm.mysql-3.0.2-bin.jar)  
  12.     private String className="org.gjt.mm.mysql.Driver";  
  13.     private String url="jdbc:mysql://localhost:3306/lwc";  
  14. JDBC连接PostgreSQL(pgjdbc2.jar)  
  15.     private String className="org.postgresql.Driver";  
  16.     private String url="jdbc:postgresql://localhost/lwc";  
  17. JDBC连接Oracle(classes12.jar)  
  18.     private String className="oracle.jdbc.driver.OracleDriver";  
  19.     private String url="jdbc:oracle:thin:@localhost:1521:lwc";  

JDBC连接数据库案例

[java]  view plain copy
  1. package com.itlwc;  
  2.   
  3. import java.sql.Connection;  
  4. import java.sql.DriverManager;  
  5. import java.sql.ResultSet;  
  6. import java.sql.SQLException;  
  7. import java.sql.Statement;  
  8.   
  9. public class DBConnection {  
  10.     private static Connection conn = null;  
  11.     private String user = "";  
  12.     private String password = "";  
  13.     private String className = "com.microsoft.jdbc.sqlserver.SQLServerDriver";  
  14.     private String url = "jdbc:microsoft:sqlserver://"  
  15.             + "localhost:1433;SelectMethod=Cursor;dataBaseName=lwc";  
  16.   
  17.     private DBConnection() {  
  18.         try {  
  19.             Class.forName(this.className);  
  20.             conn = DriverManager.getConnection(url, user, password);  
  21.             System.out.println("连接数据库成功");  
  22.         } catch (ClassNotFoundException e) {  
  23.             System.out.println("连接数据库失败");  
  24.         } catch (SQLException e) {  
  25.             System.out.println("连接数据库失败");  
  26.         }  
  27.     }  
  28.   
  29.     public static Connection getConn() {  
  30.         if (conn == null) {  
  31.             conn = (Connection) new DBConnection();  
  32.         }  
  33.         return conn;  
  34.     }  
  35.   
  36.     // 关闭数据库  
  37.     public static void close(ResultSet rs, Statement state, Connection conn) {  
  38.         if (rs != null) {  
  39.             try {  
  40.                 rs.close();  
  41.             } catch (SQLException e) {  
  42.                 e.printStackTrace();  
  43.             }  
  44.             rs = null;  
  45.         }  
  46.         if (state != null) {  
  47.             try {  
  48.                 state.close();  
  49.             } catch (SQLException e) {  
  50.                 e.printStackTrace();  
  51.             }  
  52.             state = null;  
  53.         }  
  54.         if (conn != null) {  
  55.             try {  
  56.                 conn.close();  
  57.             } catch (SQLException e) {  
  58.                 e.printStackTrace();  
  59.             }  
  60.             conn = null;  
  61.         }  
  62.     }  
  63.   
  64.     // 测试数据库连接是否成功  
  65.     public static void main(String[] args) {  
  66.         getConn();  
  67.     }  
  68. }  

基本CURD

[java]  view plain copy
  1. 获取数据库连接请查考JDBC连接常用数据库  
  2. private Connection conn = DBConnection.getConn();  

增加方法

[java]  view plain copy
  1. 使用拼sql增加  
  2. public void add1(Student student) {  
  3.     String sql = "insert into student values(" + student.getId() + ",'"  
  4.             + student.getCode() + "','" + student.getName() + "',"  
  5.             + student.getSex() + "," + student.getAge() + ")";  
  6.     PreparedStatement ps = null;  
  7.     try {  
  8.         ps = conn.prepareStatement(sql);  
  9.         ps.executeUpdate();  
  10.     } catch (SQLException e) {  
  11.         e.printStackTrace();  
  12.     }  
  13.     DBConnection.close(null, ps, conn);  
  14. }  
  15. 使用替换变量增加  
  16. public void add2(Student student) {  
  17.     String sql = "insert into student values(?,?,?,?,?)";  
  18.     PreparedStatement ps = null;  
  19.     try {  
  20.         ps = conn.prepareStatement(sql);  
  21.         ps.setString(1, student.getCode());  
  22.         ps.setString(2, student.getName());  
  23.         ps.setString(3, student.getSex());  
  24.         ps.setString(4, student.getAge());  
  25.         ps.setString(5, student.getId());  
  26.         ps.executeUpdate();  
  27.     } catch (SQLException e) {  
  28.         e.printStackTrace();  
  29.     }  
  30.     DBConnection.close(null, ps, conn);  
  31. }  

删除方法

[java]  view plain copy
  1. 使用拼sql删除  
  2. public void delete1(String id) {  
  3.     String sql = "delete from student where id='" + id+"'";  
  4.     PreparedStatement ps = null;  
  5.     try {  
  6.         ps = conn.prepareStatement(sql);  
  7.         ps.executeUpdate();  
  8.     } catch (SQLException e) {  
  9.         e.printStackTrace();  
  10.     }  
  11.     DBConnection.close(null, ps, conn);  
  12. }  
  13. 使用替换变量删除  
  14. public void delete2(String id) {  
  15.     String sql = "delete from student where id=?";  
  16.     PreparedStatement ps = null;  
  17.     try {  
  18.         ps = conn.prepareStatement(sql);  
  19.         ps.setString(1, id);  
  20.         ps.executeUpdate();  
  21.     } catch (SQLException e) {  
  22.         e.printStackTrace();  
  23.     }  
  24.     DBConnection.close(null, ps, conn);  
  25. }  

修改方法

[java]  view plain copy
  1. 使用拼sql修改  
  2. public void update1(Student student) {  
  3.     String sql = "update student set code='" + student.getCode()  
  4.             + "',name='" + student.getName() + "',sex=" + student.getSex()  
  5.             + ",age=" + student.getAge() + " where id=" + student.getId();  
  6.     PreparedStatement ps = null;  
  7.     try {  
  8.         ps = conn.prepareStatement(sql);  
  9.         ps.executeUpdate();  
  10.     } catch (SQLException e) {  
  11.         e.printStackTrace();  
  12.     }  
  13.     DBConnection.close(null, ps, conn);  
  14. }  
  15. 使用替换变量修改  
  16. public void update2(Student student) {  
  17.     String sql = "update student set code=?,name=?,sex=?,age=? where id=?";  
  18.     PreparedStatement ps = null;  
  19.     try {  
  20.         ps = conn.prepareStatement(sql);  
  21.         ps.setString(1, student.getCode());  
  22.         ps.setString(2, student.getName());  
  23.         ps.setString(3, student.getSex());  
  24.         ps.setString(4, student.getAge());  
  25.         ps.setString(5, student.getId());  
  26.         ps.executeUpdate();  
  27.     } catch (SQLException e) {  
  28.         e.printStackTrace();  
  29.     }  
  30.     DBConnection.close(null, ps, conn);  
  31. }  

查询方法

[java]  view plain copy
  1. 查询得到一个对象  
  2. public Student findById(int id) {  
  3.     String sql = "select * from student where id=" + id;  
  4.     Student student = new Student();  
  5.     PreparedStatement ps = null;  
  6.     ResultSet rs = null;  
  7.     try {  
  8.         ps = conn.prepareStatement(sql);  
  9.         rs = ps.executeQuery();  
  10.         if (rs.next()) {  
  11.             student.setId(rs.getString(1));  
  12.             student.setCode(rs.getString(2));  
  13.             student.setName(rs.getString(3));  
  14.             student.setSex(rs.getString(4));  
  15.             student.setAge(rs.getString(5));  
  16.         }  
  17.     } catch (SQLException e) {  
  18.         e.printStackTrace();  
  19.     }  
  20.     DBConnection.close(rs, ps, conn);  
  21.     return student;  
  22. }  
  23. 查询得到一组数据  
  24. @SuppressWarnings("unchecked")  
  25. public List find() {  
  26.     String sql = "select * from student";  
  27.     List list = new ArrayList();  
  28.     PreparedStatement ps = null;  
  29.     ResultSet rs = null;  
  30.     try {  
  31.         ps = conn.prepareStatement(sql);  
  32.         rs = ps.executeQuery();  
  33.         while (rs.next()) {  
  34.             Student student = new Student();  
  35.             student.setId(rs.getString(1));  
  36.             student.setCode(rs.getString(2));  
  37.             student.setName(rs.getString(3));  
  38.             student.setSex(rs.getString(4));  
  39.             student.setAge(rs.getString(5));  
  40.             list.add(student);  
  41.         }  
  42.     } catch (SQLException e) {  
  43.         e.printStackTrace();  
  44.     }  
  45.     DBConnection.close(rs, ps, conn);  
  46.     return list;  
  47. }  

统计数据库总条数

[java]  view plain copy
  1. public int getRows() {  
  2.     int totalRows = 0;  
  3.     String sql = "select count(*) as totalRows from student";  
  4.     PreparedStatement ps = null;  
  5.     ResultSet rs = null;  
  6.     try {  
  7.         ps = conn.prepareStatement(sql);  
  8.         rs = ps.executeQuery();  
  9.         if (rs.next()) {  
  10.             totalRows = Integer.valueOf(rs.getString("totalRows"));  
  11.         }  
  12.     } catch (SQLException e) {  
  13.         e.printStackTrace();  
  14.     }  
  15.     DBConnection.close(rs, ps, conn);  
  16.     return totalRows;  
  17. }  

执行存储过程

[java]  view plain copy
  1. 第一种  
  2.     public String retrieveId(String tableName,String interval) throws SQLException {    
  3.         Connection conn = DBConnection.getConn();    
  4.         String sql = "exec p_xt_idbuilder '" + tableName + "','" + interval+ "'";    
  5.         PreparedStatement ps = conn.prepareStatement(sql);  
  6.         ResultSet rs = ps.executeQuery();  
  7.         String maxId = "";    
  8.         if(rs.next()){    
  9.             maxId = rs.getString("bh");    
  10.         }    
  11.         DBConnection.close(rs, ps, conn);    
  12.         return maxId;    
  13.     }  
  14. 第二种  
  15.     public String retrieveId(String tableName,String interval) throws SQLException {  
  16.         Connection conn = DBConnection.getConn();  
  17.         CallableStatement cs = conn.prepareCall("{call p_xt_idbuilder(?,?,?)}");  
  18.         cs.setString(1, tableName);  
  19.         cs.setString(2, interval);  
  20.         cs.registerOutParameter(3,java.sql.Types.VARCHAR);  
  21.         cs.executeUpdate();  
  22.         String maxId = "";  
  23.         maxId=cs.getString(3);     
  24.         DBConnection.close(null, cs, conn);  
  25.         return maxId;  
  26.     }  
 阅读全部内容  
点击查看
特别重申：本篇文档资料为 “好网角收藏夹” 注册用户(收藏家)上传共享，仅供参考之用，请谨慎辨别，不代表本站任何观点。
好网角收藏夹为网友提供资料整理云存储服务，仅提供信息存储共享平台。

信息删除举报或发邮件到：dongye2016@qq.com
TOP
下载连接中...
返回

提示信息

确定 返回

添加文章收藏

更多设置 (选填)

阅读权限：

转藏到我的收藏夹

非法或侵权内容举报：

提交 (如果是侵权投诉，请将相关证明材料发送到邮箱：374524223@qq.com)

登录好网角

 
获取
登录/注册
QQ 微博微信
注册是视为同意用户服务协议账号密码登录

loading