栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java数据库开发之JDBC的完整封装兼容多种数据库

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java数据库开发之JDBC的完整封装兼容多种数据库

目前此代码我只用过mysql和oracle数据库测试过,但相信其它数据库都是可以的,只要导入你需要操作的数据库jar包,驱动等就可,下面上代码:

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetmetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 

public class JDBCUtil {
 
	private static String driver = null;
	private static String url = null;
	private static String username = null;
	private static String password = null;
	
	private CallableStatement callableStatement = null;//创建CallableStatement对象   
	private Connection conn = null;
	private PreparedStatement pst = null;
	private ResultSet rst = null;
	
  
  
	public JDBCUtil(String driver,String url ,String username,String password) {
		this.driver = driver;
		this.url = url;
		this.username = username;
		this.password = password;
	}
	
    
  public Connection getConnection() {  
    try {  
    	 // 加载数据库驱动程序  
      try {
				Class.forName(driver);
			} catch (ClassNotFoundException e) {
				System.out.println("加载驱动错误");  
	      System.out.println(e.getMessage()); 
				e.printStackTrace();
			} 
      // 获取连接  
    	conn = DriverManager.getConnection(url, username,  
    			password);  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    }  
    return conn;  
  }  
  
    
  public int executeUpdate(String sql, Object[] params) {  
    // 受影响的行数  
    int affectedLine = 0;  
      
    try {  
      // 获得连接  
      conn = this.getConnection();  
      // 调用SQL   
      pst = conn.prepareStatement(sql);  
 
      // 参数赋值  
      if (params != null) {  
 for (int i = 0; i < params.length; i++) {  
 	pst.setObject(i + 1, params[i]);  
 }  
      }  
      
      // 执行  
      affectedLine = pst.executeUpdate();
  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 释放资源  
      closeAll();  
    }  
    return affectedLine;  
  }  
  
    
  private ResultSet executeQueryRS(String sql, Object[] params) {  
    try {  
      // 获得连接  
      conn = this.getConnection();  
 
      // 调用SQL  
      pst = conn.prepareStatement(sql);  
 
      // 参数赋值  
      if (params != null) {  
 for (int i = 0; i < params.length; i++) {  
 	pst.setObject(i + 1, params[i]);  
 }  
      }  
 
      // 执行  
      rst = pst.executeQuery();  
  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    }   
  
    return rst;  
  }  
    
    
  public Object executeQuerySingle(String sql, Object[] params) {  
    Object object = null;  
    try {  
      // 获得连接  
      conn = this.getConnection();  
 
      // 调用SQL  
      pst = conn.prepareStatement(sql);  
 
      // 参数赋值  
      if (params != null) {  
 for (int i = 0; i < params.length; i++) {  
 	pst.setObject(i + 1, params[i]);  
 }  
      }  
 
      // 执行  
      rst = pst.executeQuery();  
  
      if(rst.next()) {  
 object = rst.getObject(1);  
      }  
 
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      closeAll();  
    }  
  
    return object;  
  }  
  
    
  public List excuteQuery(String sql, Object[] params) {  
    // 执行SQL获得结果集  
    ResultSet rs = executeQueryRS(sql, params);  
      
    // 创建ResultSetmetaData对象  
    ResultSetmetaData rsmd = null;  
      
    // 结果集列数  
    int columnCount = 0;  
    try {  
      rsmd = rs.getmetaData();  
 
      // 获得结果集列数  
      columnCount = rsmd.getColumnCount();  
    } catch (SQLException e1) {  
      System.out.println(e1.getMessage());  
    }  
  
    // 创建List  
    List list = new ArrayList();  
  
    try {  
      // 将ResultSet的结果保存到List中  
      while (rs.next()) {  
 Map map = new HashMap();  
 for (int i = 1; i <= columnCount; i++) {  
   map.put(rsmd.getColumnLabel(i), rs.getObject(i));  
 }  
 list.add(map);//每一个map代表一条记录,把所有记录存在list中  
      }  
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 关闭所有资源  
      closeAll();  
    }  
  
    return list;  
  }  
    
    
  public Object excuteQuery(String sql, Object[] params,int outParamPos, int SqlType) {  
    Object object = null;  
    conn = this.getConnection();  
    try {  
      // 调用存储过程  
    	// prepareCall:创建一个 CallableStatement 对象来调用数据库存储过程。
      callableStatement = conn.prepareCall(sql);  
 
      // 给参数赋值  
      if(params != null) {  
 for(int i = 0; i < params.length; i++) {  
   callableStatement.setObject(i + 1, params[i]);  
 }  
      }  
 
      // 注册输出参数  
      callableStatement.registerOutParameter(outParamPos, SqlType);  
 
      // 执行  
      callableStatement.execute();  
 
      // 得到输出参数  
      object = callableStatement.getObject(outParamPos);  
 
    } catch (SQLException e) {  
      System.out.println(e.getMessage());  
    } finally {  
      // 释放资源  
      closeAll();  
    }  
      
    return object;  
  }  
  
    
  private void closeAll() {  
    // 关闭结果集对象  
    if (rst != null) {  
      try {  
 rst.close();  
      } catch (SQLException e) {  
 System.out.println(e.getMessage());  
      }  
    }  
  
    // 关闭PreparedStatement对象  
    if (pst != null) {  
      try {  
 pst.close();  
      } catch (SQLException e) {  
 System.out.println(e.getMessage());  
      }  
    }  
      
    // 关闭CallableStatement 对象  
    if (callableStatement != null) {  
      try {  
 callableStatement.close();  
      } catch (SQLException e) {  
 System.out.println(e.getMessage());  
      }  
    }  
  
    // 关闭Connection 对象  
    if (conn != null) {  
      try {  
 conn.close();  
      } catch (SQLException e) {  
 System.out.println(e.getMessage());  
      }  
    }    
  }  
}

使用的时候直接new一个JDBCUtil类,然后对传入对应的sql语句,例:

public class JDBCTest {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		JDBCUtil jdbcUtil = new JDBCUtil("com.mysql.jdbc.Driver",
		"jdbc:mysql://localhost:3306/myhelp?useUnicode=true&characterEncoding=utf-8&useSSL=false","root","142014068");
		String sql = "delete from menu_detial where count=6";
		System.out.println(jdbcUtil.executeUpdate(sql, null));
	}
}

更多关于java数据库开发的文章请查看下面的相关链接

转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号