jdbc,基本数据库命令封装

这个项目是根据jdbc,连接池,封装,object类,泛型,反射,io,lamode表达式写的一个简单的框架,里面有数据库基本的使用,通过调用该类方法,可以减少代码冗余

/** 今日解签,宜下江南* 从此江湖少了个天道,武道一肩挑的吕祖转世,* 多了个愿为徐胭脂再修三百年的洪洗象.* 　ヽ＼　 /／* 　 　 ∧∧　｡* 　 ﾟ (ﾟ∀ﾟ)っ ﾟ* 　　　(っﾉ* 　 　　`Ｊ*/package zy.db;import com.alibaba.druid.pool.DruidDataSource;import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Field;
import java.sql.*;
import java.util.*;/*** 数据库工具类v2.0 将访问数据库得公共代码抽取: 1.加载驱动 2.获取连接 6.关闭资源** @author liqiuyang**/
public class DBUtils {/** 驱动类路径 */private static String DRIVER_CLASS;/** url地址 */private static String URL;/** 数据库服务器用户名 */private static String USER;/** 数据库服务器密码 */private static String PASSWORD;/**最大活动链接数*/private static int MAX_ACTIVE;/**最长等待连接获取的时间*/private static int MAX_WAIT;/**初始连接数*/private static int INIT_SIZE;/**声明连接池引用*/private static DruidDataSource ds;static {try {// 读取属性文件获取连接数据库相关的字符串InputStream is = DBUtils.class.getResourceAsStream("/jdbc2.properties");// 创建属性对象Properties p = new Properties();// 加载包含属性信息的输入流p.load(is);// 根据属性名获取属性DRIVER_CLASS = p.getProperty("driver");URL = p.getProperty("url");USER = p.getProperty("user");PASSWORD = p.getProperty("password");//获取连接池相关配置MAX_ACTIVE = Integer.parseInt(p.getProperty("pool.maxActive"));INIT_SIZE = Integer.parseInt(p.getProperty("pool.initSize"));MAX_WAIT = Integer.parseInt(p.getProperty("pool.maxWait"));//初始化连接池init();} catch (IOException e) {e.printStackTrace();}}public static void init() {if(ds == null || ds.isClosed()) {ds = new DruidDataSource();}ds.setDriverClassName(DRIVER_CLASS);ds.setUrl(URL);ds.setUsername(USER);ds.setPassword(PASSWORD);ds.setMaxActive(MAX_ACTIVE);ds.setInitialSize(INIT_SIZE);ds.setMaxWait(MAX_WAIT);}/*** 获取数据库连接对象** @return*/public static synchronized Connection getConn() {try {//当连接池被关闭或者为null重新初始化if(ds == null || ds.isClosed()) {init();}//从连接池获取一个连接并返回return ds.getConnection();} catch (SQLException e) {e.printStackTrace();}return null;}/*** 关闭资源** @param rs* @param stat* @param conn*/public static void close(ResultSet rs, Statement stat, Connection conn) {try {if (rs != null)rs.close();if (stat != null)stat.close();if (conn != null)conn.close();} catch (SQLException e) {e.printStackTrace();}}/*** 封装通用的更行操作:insert update delete** @param sql* @param params* @return*/public static boolean exeUpdate(Connection conn,String sql,Object... params) {PreparedStatement ps = null;try {ps = conn.prepareStatement(sql);if (params != null) {for (int i = 0; i < params.length; i++) {ps.setObject(i + 1, params[i]);}}return ps.executeUpdate() > 0;} catch (SQLException e) {e.printStackTrace();} finally {close(null, ps, null);}return false;}/*** 封装通用查询单条数据的方法** @param <T>* @param t* @param sql* @param params* @return*/public static <T> T queryOne(Class<T> t, String sql, Object... params) {// 获取查询到的数组集合List<Map<String, Object>> list = queryMaps(sql, params);if (list.size() > 0) {// 获取一个map集合Map<String, Object> map = list.get(0);// 将map集合转换为javaBeanreturn mapToBean(map, t);}return null;}/*** 封装查询多条数据** @param <T>* @param t* @param sql* @param params* @return*/public static <T> List<T> queryList(Class<T> t, String sql, Object... params) {List<T> list = new ArrayList<T>();// 获取所有查询到的数据List<Map<String, Object>> maps = queryMaps(sql, params);maps.forEach(m -> {// 将map转换为javaBeanT obj = mapToBean(m, t);// 将javabean装入listlist.add(obj);});return list;}/*** 将map集合转换为一个确定的类型** @param <T>* @param map* @param t* @return*/public static <T> T mapToBean(Map<String, Object> map, Class<T> t) {T obj = null;try {// 根据提供的类型创建对应类型的objectobj = t.newInstance();// 获取class中所有fieldField[] fislds = t.getDeclaredFields();// 遍历获取每一个属性对象for (Field field : fislds) {// 获取属性名String fname = field.getName();// 获取属性Object values = map.get(fname);if (values != null) {// 设置属性对象的可访问性field.setAccessible(true);// 将从map中获取的值设置给属性obj.name=xxfield.set(obj, values);}}} catch (InstantiationException e) {e.printStackTrace();} catch (IllegalAccessException e) {e.printStackTrace();}return obj;}/*** 执行相关查询之后并将结果返回List<Map<String,Object>> 集合** @param sql* @param params* @return*/public static List<Map<String, Object>> queryMaps(String sql, Object... params) {List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();Connection conn = getConn();PreparedStatement ps = null;ResultSet rs = null;try {// 获取预处理sql命令的对象ps = conn.prepareStatement(sql);if (params != null) {for (int i = 0; i < params.length; i++) {// 对指定位置的占位符填充值(预处理)ps.setObject(i + 1, params[i]);}// 执行查询获取结果rs = ps.executeQuery();// 获取结果集的元数据对象ResultSetMetaDateResultSetMetaData rsmd = rs.getMetaData();// 获取总查询数int columnCount = rsmd.getColumnCount();// 遍历结果集while (rs.next()) {// 声明map集合存储Map<String, Object> map = new HashMap<String, Object>();// 遍历获取每一列信息for (int i = 1; i <= columnCount; i++) {// 获取列名称String key = rsmd.getColumnName(i);// 获取列标签String lable = rsmd.getColumnLabel(i);// 获取列值Object values = rs.getObject(lable);// 将取到的每一列的列名与列值存储到mapmap.put(key, values);}// 将map集合装入list集合list.add(map);}}} catch (SQLException e) {e.printStackTrace();} finally {close(rs, ps, conn);}return list;}/*** 根据提供的查询语句以及查询参数,返回符合条件的数目** @param sql* @param params* @return*/public static int queryCount(String sql, Object... params) {Connection conn = getConn();PreparedStatement ps = null;ResultSet rs = null;try {ps = conn.prepareStatement(sql);if (params != null) {for (int i = 0; i < params.length; i++) {ps.setObject(i + 1, params[i]);}}rs = ps.executeQuery();if (rs.next()) {return rs.getInt(1);}} catch (SQLException e) {e.printStackTrace();}return 0;}public static void main(String[] args) {}
}

这算是到目前为止写的最复杂的工具类,综合了很多前面的知识,很值得研究

jdbc,基本数据库命令封装相关推荐

Spring框架对JDBC的简单封装。提供了一个JDBCTemplate对象简化JDBC的开发
Spring JDBC * Spring框架对JDBC的简单封装.提供了一个JDBCTemplate对象简化JDBC的开发 * 步骤: 1. 导入jar包 ...
自己动手制作的一个JDBC的套件封装，求指导
一.背景 Java开发人员现在对数据库的操作一般会用到诸如像Hibernate,Mybatis,SpringJdbcTemplate等ORM组件,但是这些组件是怎样从原始的编码方式一步步封装过来的呢 ...
java jdbc 增删改封装_JAVA JDBC 常规增删改查简单封装
JAVA JDBC 常规增删改查简单封装,可满足大多基本要求作用: 1, 查询列表是直接返回List对象,不必再遍历: 2, 单条查询直接返回对象: 3, 执行sql仅需一个方法搞定: packag ...
原始JDBC连接与封装后的JDBC
JDBC连接数据库操作步骤: 准备jar包mysql-connector-java-5.1.0-bin.jar 加载驱动Class.forName("com.mysql.jdbc.Driv ...
JDBC基本简易封装代码
代码如下(示例): public class DBUtils2 {/**驱动类路径*/private static final String Driver_CLASS ="com.mysql ...
MySQL JDBC常用知识,封装工具类,时区问题配置,SQL注入问题
JDBC JDBC介绍 Sun公司为了简化开发人员的(对数据库的统一)操作,提供了(Java操作数据库的)规范,俗称JDBC,这些规范的由具体由具体的厂商去做对于开发人员来说,我们只需要掌握JDBC ...
mysql设置约束l命令_2、MYSQL 基本数据库命令及约束
[注]sql语句注意不要忘了后面的 " : ",表示结束符 1.如何登陆数据库服务器 C:\Users\zhg>mysql -uroot -p Enter passwo ...
jdbc封装mysql_实用JDBC数据库查询封装
public static List queryList(String preSql, String className, Connection con, int offset, int pagele ...
java mvc数据库封装_Springmvc对就jdbc封装的操作
解释: JdbcTemplate 封装常用的JDBC方法 HibernateTemplate 封装常用Hibernate方法 JdbcDaoSupport JDBC数据访问对象的基类 Hibern ...
jdbc封装mysql_用Java手动封装JDBC连接池（一）
JDBC存在的问题代码的冗余:在对数据库进行增删改查时,每个操作的JDBC流程和SQL执行代码的流程都一样,造成代码的冗余,所以我们可以把冗余的部分封装起来,封装之后,我们就不用再去写JDBC流程, ...

jdbc,基本数据库命令封装

jdbc,基本数据库命令封装相关推荐

最新文章

热门文章