数据库Dao层抽象出BasicDao类 | 许久没碰Java了、致Java初学者

前言: 最近呢,接了一个PLC-ERP的项目,要使用RS232串口通信,时间很赶、实在没有办法了,就是用Java动身喽。好早学习Java的时候,仅仅封装了一个连接以及关闭数据库的类,这次呢,那肯定要抽象出操作的Event方法的。


有了BasicDao之后,在简单的增删改查中,你会体验到特别方便!


如何连接数据库就不说了(jdbc),重点在于封装操作MySQL数据库的方法,还是直接看代码!

package com.samego.java.dev.dao.basic;

import com.samego.java.dev.common.BasicConnection;
import com.samego.java.dev.dao.presenter.SameGoToolDao;
import org.apache.commons.beanutils.BeanUtils;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

/**
 * BaseDao的实现
 * 所有的Dao都要继承该类
 * Created by alic(AlicFeng) on 17-5-24.
 * Email is alic@samego.com
 */
public class BasicDao {
    private Connection connection;
    private PreparedStatement preparedStatement;
    private ResultSet resultSet;

    /**
     * 更新的通用方法 including update/insert/delete
     *
     * @param sql         SQL
     * @param paramsValue prepareStatement sql语句中占位符对应的值(如果没有占位符,传入null)
     * @param logMessage  日志信息
     * @return 数据库更新的数目
     */
    public int update(String sql, Object[] paramsValue, String[] logMessage) {
        int result = -1;
        try {
            connection = BasicConnection.getConnection();
            preparedStatement = connection.prepareStatement(sql);
            int count = preparedStatement.getParameterMetaData().getParameterCount();
            if (paramsValue != null && paramsValue.length > 0) {
                //循环给参数赋值
                for (int i = 0; i < count; i++) {
                    preparedStatement.setObject(i + 1, paramsValue[i]);
                }
            }
            result = preparedStatement.executeUpdate();
        } catch (SQLException e) {
            this.writeLog(logMessage);
            e.printStackTrace();
        } finally {
            BasicConnection.closeConnection(null, preparedStatement, connection);
        }
        return result;
    }

    /**
     * 查询通用方法
     *
     * @param sql         SQL
     * @param paramsValue prepareStatement
     * @param tClass      对象的类
     * @param logMessage  日志
     * @param <T>         返回类的集合
     * @return 返回类的集合
     */
    public <T> List<T> query(String sql, Object[] paramsValue, Class<T> tClass, String[] logMessage) {
        List<T> list = new ArrayList<>();
        connection = BasicConnection.getConnection();
        try {
            preparedStatement = connection.prepareStatement(sql);
            if (paramsValue != null && paramsValue.length > 0) {
                for (int i = 0; i < paramsValue.length; i++) {
                    preparedStatement.setObject(i + 1, paramsValue[i]);
                }
            }
            resultSet = preparedStatement.executeQuery();
            ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
            int columnCount = resultSetMetaData.getColumnCount();
            T t;
            while (resultSet.next()) {
                t = tClass.newInstance();
                for (int i = 0; i < columnCount; i++) {
                    String columnName = resultSetMetaData.getColumnName(i + 1);
                    Object value = resultSet.getObject(columnName);
                    BeanUtils.copyProperty(t, columnName, value);
                }
                list.add(t);
            }
        } catch (Exception e) {
            this.writeLog(logMessage);
            e.printStackTrace();
        } finally {
            BasicConnection.closeConnection(resultSet, preparedStatement, connection);
        }
        return list;
    }

    /**
     * @param sql         SQL
     * @param paramsValue prepareStatement
     * @param columnName  查询的字段名
     * @param logMessage  日志
     * @return 数量值
     */
    public Object queryByOne(String sql, Object[] paramsValue, String columnName, String[] logMessage) {
        Object result = null;
        connection = BasicConnection.getConnection();
        try {
            preparedStatement = connection.prepareStatement(sql);
            if (paramsValue != null && paramsValue.length > 0) {
                for (int i = 0; i < paramsValue.length; i++) {
                    preparedStatement.setObject(i + 1, paramsValue[i]);
                }
            }
            resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {
                result = resultSet.getObject(columnName);
            }
        } catch (Exception e) {
            this.writeLog(logMessage);
            e.printStackTrace();
        } finally {
            BasicConnection.closeConnection(resultSet, preparedStatement, connection);
        }
        return result;
    }

    /**
     * 写日志
     *
     * @param logMessage 日志信息
     */
    private void writeLog(String[] logMessage) {
        if (null != logMessage && 2 == logMessage.length) {
            SameGoToolDao.queryLog(logMessage[0], logMessage[1], false);
        }
    }
}

封装好了之后,那么我们就早Dao类继承,使用简洁又简单!看代码

  • update
    @Override
    public boolean updateFinishPerProductTimeUnit(int time) {
        boolean result = false;
        String[] logMessage = {"更改系统值", "修改每一件产品的用时失败"};
        Object[] paramValues = {time};
        if (super.update(SQLCommands.UPDATE_PER_PRODUCT_TIME_UNIT, paramValues, logMessage) > 0) {
            result = true;
            ETCVar.PRODUCT_UNIT_TIME = time;
            SameGoToolDao.queryLog("更改系统值", "修改每一件产品的用时成功", true);
        }
        return result;
    }
  • query
    @Override
    public ArrayList<MachineWork> machineWorkSign() {
        ArrayList<MachineWork> machineWorks = super.query(SQLCommands.MACHINE_WORK_SIGN_CHECK, null, MachineWork.class, null);
    }
  • queryByOne
    @Override
    public int getLastMonthFinishedOrderNum() {
        Object[] paramsValues = {Strings.ORDER_STATUS_LIST[2]};
        String[] logMessage = {"报告报表", "查询上个月的订单数失败"};
        int lastMonthOrderFinishedNum = Integer.parseInt(super.queryByOne(SQLCommands.LAST_MONTH_FINISHED_ORDER_NUM, paramsValues, "order_num", logMessage).toString());
        SameGoToolDao.queryLog("报告报表", "查询上个月的订单数成功", true);
        return lastMonthOrderFinishedNum;
    }

注意: 使用到的第三方Jar有

  • org.apache.commons.beanutils.BeanUtils
  • commons-logging-1.0.4.jar这个编辑代码看不出,但是一定要引入,上面的依赖这个

个人的建议: 1、对于SQL语句呢,最好集中在一个类文件 2、使用占位符赋值-PreparedStatement,防止SQL注入


本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏JMCui

再学习之MyBatis.

一、框架基本介绍 1、概念 支持普通SQL查询、存储过程和高级映射,简化和实现了Java 数据持久化层的的开源框架,主要流行的原因在于他的简单性和易使用性。 2...

4608
来自专栏蓝天

IDL编译器实现入门

本文不对词法和语法、以及flex和bison进行介绍,如有需要,可以阅读《RPC的实现》。本文试图用直接的方式,以最短的篇幅介绍一个最简单的IDL编译器实现。...

1883
来自专栏计算机视觉与深度学习基础

Leetcode 37 Sudoku Solver 深搜基础题+位运算

Write a program to solve a Sudoku puzzle by filling the empty cells. Empty cel...

1857
来自专栏IT技术精选文摘

ZooKeeper 分布式锁实现

1272
来自专栏linux驱动个人学习

Linux内存描述之内存节点node--Linux内存管理(二)

这点前面是说的很明白了, NUMA结构下, 每个处理器CPU与一个本地内存直接相连, 而不同处理器之前则通过总线进行进一步的连接, 因此相对于任何一个CPU访问...

2032
来自专栏大学生计算机视觉学习DeepLearning

c++ 网络编程(七)TCP/IP LINUX下 socket编程 基于套接字的标准I/O函数使用 与 fopen,feof,fgets,fputs函数用法

原文链接:https://www.cnblogs.com/DOMLX/p/9614820.html

1654
来自专栏Linyb极客之路

编码习惯之参数校验和国际化规范

今天我们说说参数校验和国际化,这些代码没有什么技术含量,却大量充斥在业务代码上,很可能业务代码只有几行,参数校验代码却有十几行,非常影响代码阅读,所以很有必要把...

3066
来自专栏Danny的专栏

用两个小例子来解释单例模式中的“双重锁定”

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/huyuyang6688/article/...

2142
来自专栏芋道源码1024

数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 执行

本文主要基于 Sharding-JDBC 1.5.0 正式版 1. 概述 2. ExecutorEngine 2.1 ListeningExecutorServ...

3697
来自专栏武培轩的专栏

猫眼面经汇总

java.util.Collections 是一个包装类(工具类/帮助类)。它包含有各种有关集合操作的静态多态方法。此类不能实例化,就像一个工具类,用于对集合中...

1352

扫码关注云+社区