MySQL操作类(本人自己写的)
1 package com.test; 2 import java.sql.Connection; 3 import java.sql.DriverManager; 4 import java.sql.PreparedStatement; 5 import java.sql.ResultSet; 6 import java.util.Vector; 7 public class DBUtil { 8 9 //定义连接数据库需要的 10 Connection ct=null; 11 PreparedStatement pS=null; 12 ResultSet rS=null; 13 private static String url = "jdbc:mysql://"+DBSomeType.MYSQLURL+":3306/weixin?characterEncoding=UTF-8&autoReconnect=true"; 14 private static String driverName = "com.mysql.jdbc.Driver"; 15 16 /** 17 * 数据库查询,本操作查询完需手动关闭连接 18 * @param sql 19 * @param params 20 * @return 查询结果ResultSet 21 */ 22 public ResultSet getSlect(String sql,Object ...params){ 23 Vector rowDate=new Vector(); 24 Vector columnDate =new Vector(); 25 try { 26 ct = connectWithDB(); 27 pS=ct.prepareStatement(sql); 28 for(int i = 0;i < params.length;i++){ 29 pS.setObject(i+1, params[i]); 30 } 31 rS=pS.executeQuery(); 32 } catch (Exception e) { 33 // TODO: handle exception 34 }finally{ 35 return rS; 36 } 37 } 38 39 /************修改数据库操作*********************/ 40 public int update(String sql,Object ...params){ 41 int executeUpdate_int = 0; 42 try { 43 ct = connectWithDB(); 44 pS=ct.prepareStatement(sql); 45 for(int i = 0;i < params.length;i++){ 46 pS.setObject(i+1, params[i]); 47 } 48 //执行操作 49 executeUpdate_int = pS.executeUpdate(); 50 System.out.println("executeUpdate_int = "+executeUpdate_int); 51 } catch (Exception e) { 52 // TODO: handle exception 53 }finally{ 54 shutDownDB(); 55 return executeUpdate_int; 56 } 57 } 58 59 /************连接数据库*********************/ 60 private Connection connectWithDB(){ 61 Connection connection = null; 62 try { 63 Class.forName(driverName); 64 connection= DriverManager.getConnection(url, DBSomeType.ROOTUSERNAME, DBSomeType.ROOTPASSWORD); 65 } catch (Exception e) { 66 // TODO: handle exception 67 } 68 return connection; 69 } 70 71 /************关闭数据库的相关连接*********************/ 72 public void shutDownDB(){ 73 try 74 { 75 if(rS!=null) rS.close(); 76 if(pS!=null) pS.close(); 77 if(ct!=null) ct.close(); 78 } catch (Exception e2) 79 { 80 e2.printStackTrace(); 81 // TODO: handle exception 82 } 83 } 84 85 }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。