package com.xu.test; 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; /** * 数据库连接类 * 说明:封装了 无参,有参,存储过程的调用 * @author iflytek * */ public class ConnectionDB { /** * 数据库驱动类名称 */ private static final String DRIVER = "com.mysql.jdbc.Driver"; /** * 连接字符串 */ private static final String URLSTR = "jdbc:mysql://localhost:3306/website"; /** * 用户名 */ private static final String USERNAME = "root"; /** * 密码 */ private static final String USERPASSWORD = "123456"; /** * 创建数据库连接对象 */ private Connection connnection = null; /** * 创建PreparedStatement对象 */ private PreparedStatement preparedStatement = null; /** * 创建CallableStatement对象 */ private CallableStatement callableStatement = null; /** * 创建结果集对象 */ private ResultSet resultSet = null; static { try { // 加载数据库驱动程序 Class.forName(DRIVER); } catch (ClassNotFoundException e) { System.out.println("加载驱动错误"); System.out.println(e.getMessage()); } } /** * 建立数据库连接 * @return 数据库连接 */ public Connection getConnection() { try { // 获取连接 connnection = DriverManager.getConnection(URLSTR, USERNAME, USERPASSWORD); } catch (SQLException e) { System.out.println(e.getMessage()); } return connnection; } /** * insert update delete SQL语句的执行的统一方法 * @param sql SQL语句 * @param params 参数数组,若没有参数则为null * @return 受影响的行数 */ public int executeUpdate(String sql, List<Object> params) { // 受影响的行数 int affectedLine = 0; try { // 获得连接 connnection = this.getConnection(); // 调用SQL preparedStatement = connnection.prepareStatement(sql); // 参数赋值 if (params != null) { for (int i = 0; i < params.size(); i++) { preparedStatement.setObject(i + 1, params.get(i)); } } // 执行 affectedLine = preparedStatement.executeUpdate(); } catch (SQLException e) { System.out.println(e.getMessage()); } finally { // 释放资源 closeAll(); } return affectedLine; } /** * SQL 查询将查询结果直接放入ResultSet中 * @param sql SQL语句 * @param params 参数数组,若没有参数则为null * @return 结果集 */ public ResultSet executeQueryRS(String sql, List<Object> params) { try { // 获得连接 connnection = this.getConnection(); // 调用SQL preparedStatement = connnection.prepareStatement(sql); // 参数赋值 if (params != null) { for (int i = 0; i < params.size(); i++) { preparedStatement.setObject(i + 1, params.get(i)); } } // 执行 resultSet = preparedStatement.executeQuery(); } catch (SQLException e) { System.out.println(e.getMessage()); } return resultSet; } /** * SQL 查询将查询结果:一行一列 * @param sql SQL语句 * @param params 参数数组,若没有参数则为null * @return 结果集 */ public Object executeQuerySingle(String sql, Object[] params) { Object object = null; try { // 获得连接 connnection = this.getConnection(); // 调用SQL preparedStatement = connnection.prepareStatement(sql); // 参数赋值 if (params != null) { for (int i = 0; i < params.length; i++) { preparedStatement.setObject(i + 1, params[i]); } } // 执行 resultSet = preparedStatement.executeQuery(); if(resultSet.next()) { object = resultSet.getObject(1); } } catch (SQLException e) { System.out.println(e.getMessage()); } finally { closeAll(); } return object; } /** * 获取结果集,并将结果放在List中 * * @param sql * SQL语句 * @return List * 结果集 */ public List<Object> excuteQuery(String sql, List<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<Object> list = new ArrayList<Object>(); try { // 将ResultSet的结果保存到List中 while (rs.next()) { Map<String, Object> map = new HashMap<String, Object>(); for (int i = 1; i <= columnCount; i++) { map.put(rsmd.getColumnLabel(i), rs.getObject(i)); } list.add(map); } } catch (SQLException e) { System.out.println(e.getMessage()); } finally { // 关闭所有资源 closeAll(); } return list; } /** * 存储过程带有一个输出参数的方法 * @param sql 存储过程语句 * @param params 参数数组 * @param outParamPos 输出参数位置 * @param SqlType 输出参数类型 * @return 输出参数的值 */ public Object excuteQuery(String sql, List<Object> params,int outParamPos, int SqlType) { Object object = null; connnection = this.getConnection(); try { // 调用存储过程 callableStatement = connnection.prepareCall(sql); // 给参数赋值 if(params != null) { for(int i = 0; i < params.size(); i++) { callableStatement.setObject(i + 1, params.get(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 (resultSet != null) { try { resultSet.close(); } catch (SQLException e) { System.out.println(e.getMessage()); } } // 关闭PreparedStatement对象 if (preparedStatement != null) { try { preparedStatement.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 (connnection != null) { try { connnection.close(); } catch (SQLException e) { System.out.println(e.getMessage()); } } } }
相关推荐
连接池的初始化、创建等仔细看构造函数的doc文档,就知道如何操作。我自己用着很方便。 有两个初始化方法,分别用于初始化多个数据库对象,或者单个数据库对象。 String[] dbPoolName = { "default", "sec" }; ...
实现完全的对jdbc对象的封装,只需调用则可对数据库进行CRUD操作
对jdbc操作进行封装,使用方便。!对经常要使用jdbc操作数据的。。。应该有帮助!
本资源是对JDBC的封装,方便在项目中使用,其中BaseDao.java是对JDBC操作的封装,使用时让自己的Dao类继承即可,然后调用其中的executeQuery和executeOthe分别执行DQL和DML操作。dbinfo.properties属性文件存储基本...
简单易用的数据库封装操作,包含数据库连接池的基本实现,数据库连接可重用,所有的操作都脱离源生JDBC操作,开发人员只需要熟悉Java集合的用法,会写Sql即可轻松的使用该封装好的JDBC API写出合理的代码。...
现在的数据层的开发,大多会使用...但是在一些极端的场景下往往原生的jdbc方式操作数据库更灵活,性能更高。由于部分场景下MyBatis或JPA之类无法满足我的需求,所以我打算自己封装一套查数据库的工具类。 文章地址: ...
包括普通的增删查改,多条数据的增删改并封装成事务,结果返回到对象集合和list
自己封装好的,基于commons的DBBase,DBCP的数据库工具。支持线程池,支持直接对象化操作。即无需任何映射,只要是java标准类,属性带标准set、get,属性名称与查询结果集中字段名称相同,就可以直接查询出对象链表...
封装jdbc即是把对数据库的连接操作封装在一个类中, 外部使用无需在重新建立连接,只需写出要执行的sql语句,就可执行。 也无需关闭,所有的都封装在一个类中。
jdbc操作封装 通过配置文件获得数据库配置
基于spring jdbc的上层封装,底层jdbc操作基于JdbcTemplate,支持MySql、SqlServer、Oracle数据库,强弱类型完美结合 1、mini-jdbc:针对spring jdbc的一些不方便的地方,做了一些封装,大小写不敏感,简化了日常的...
看前面的那一版注释,加了同步,线程安全,封装了jdbc常用操作,增删改查,查询ResultSet指定位置的记录,返回ResultSet每个列的名字,查询ResultSet中记录的行数...... 含源代码,测试代码!!!! 另附API说明,powerdesign图,...
Scweery 是 Scala 一个封装了 JDBC 操作用来从 SQL 中创建 Scala 对象的工具包。 示例代码: using(petsDB) { connection => val findHogsQuery = "select name, gender from pets where family='erinaceidae' ...
封装了java使用jdbc对mysql的操作,以及java使用jdbc对mysql的事务处理,对execute、executeUpdate、executeQuery进行了封装,把繁琐的创建数据库连接对象、PreparedStatement对象、结果集对象,打开关闭连接进行了...
对 java jdbc 轻量级封装的一个jar包,可以简化jdbc操作数据库的过程.
封装了jdbc常用操作,增删改查,查询ResultSet指定位置的记录,返回ResultSet每个列的名字,查询ResultSet中记录的行数...... 含源代码,测试代码!!!! 另附API说明,powerdesign图,mysql/mssql数据库代码. 用户只需使用...
关于java对SQLite和sql的封装类,可以实现增删改,查,事务操作
在实际JDBC的使用中,存在着大量的重复代码:例如连接数据库、关闭数据库等这些操作!! 急需把传统的JDBC代码进行重构,抽象出一个通用的JDBC工具类!以后连接任何数据库,操作任何表都可以使用这个工具类来简化开发...
jdbc操作数据库demon,包括增删改的封装,查询以集合返回,以jsonArray返回等,相关博文地址:http://blog.csdn.net/sapce_fish/article/details/52764678