Java游戏服务器之数据库表存取封装

更新时间：2015年11月30日 15:11:18 作者：Metazion

这篇文章主要介绍了Java游戏服务器之数据库表存取封装的相关资料,需要的朋友可以参考下

项目涉及的数据库表并不多，但每个select、insert、update和delete都去手动拼接字符串，是很低效的，尤其在时常要修改结构的情况下。开发的一个目标就是自动化，即能自动实现的事情就不要手动去做；还有一个原则是单一化，即尽量保证数据或逻辑一个入口一个出口。这个需求可以使用一些开源库解决，但因为需求简单，目标明确，没有必要引入多余的第三方库。于是自己写了一个，至少满足当前需求。

数据库表的封装，核心类有两个，表（Table）和记录（Record）。首先需要一个Table类保存数据库表结构的描述，并籍此自动生成相应SQL语句。其次需要一个Record类自动设置SQL参数，并从返回结果集中自动生成逻辑对象。

table类表结构描述可以有两个来源，自动从数据库获取，或从配置表加载。这里选择从配置表加载的方式，一来实现简单，二来应用面更广。

下面是一个账户表的配置示例（user.xml）。

<Table name="user" primaryKey="user_id" primaryField="userId">
  <Column name="username" field="username" type="2" />
  <Column name="password" field="password" type="2" />
  <Column name="salt" field="salt" type="1" />
  <Column name="reg_time" field="registerTime" type="3" />
  <Column name="last_login_time" field="lastLoginTime" type="3" />
</Table>

只定义了一个主键，有需要可对此扩充。每列name对应数据库表的列名，field对应逻辑对象的成员变量名，type对应字段的类型，比如是int、string、timestamp等，有了名字和类型，就可以使用反射方式自动get和set数据。

Table类读取配置文件获得数据表的结构描述。

public class Table<T> {
  public class TableField {
    public static final int TYPE_INTEGER = 1;
    public static final int TYPE_STRING = 2;
    public static final int TYPE_TIMESTAMP = 3;
    public String columnName = "";
    public String fieldName = "";
    public int type = 0;
  }
  private String tableName = "";
  private TableField primaryField = new TableField();
  private ArrayList<TableField> tableFields = new ArrayList<TableField>();
  private String selectAllSql = "";
  private String selectSql = "";
  private String insertSql = "";
  private String updateSql = "";
  private String deleteSql = "";
  ...

然后生成PrepareStatement方式读写的select、insert、update和delete的预处理SQL字符串。如update：

private String generateUpdateSql() {
    String sql = "UPDATE " + tableName + " SET ";
    int size = tableFields.size();
    for (int index = 0; index < size; ++index) {
      TableField tableField = tableFields.get(index);
      String conjunction = index == 0 ? "" : ",";
      String colSql = tableField.columnName + " = ?";
      sql = sql + conjunction + colSql;
    }

    sql = sql + " WHERE " + primaryField.columnName + "=?";
    return sql;
  }

Table类的功能就这么多，下面是关键的Record类，其使用反射自动存取数据。

public class Record<T> {
  private Table<T> table = null;
  private T object = null;
  ...

模板参数T即一个表记录对应的逻辑对象。在我们的示例里，即账户数据类：

public class UserData implements Serializable {
  // 用户ID
  public int userId = 0;
  // 用户名
  public String username = "";
  // 密码
  public String password = "";
  ...

有了SQL语句，要先设置参数，才能执行。主键和普通字段分开设置。

 public int setPrimaryParams(int start, PreparedStatement pst) throws Exception {
    Table<T>.TableField primaryField = table.getPrimaryField();
    Object value = getFieldValue(primaryField);
    value = toDBValue(primaryField, value);
    pst.setObject(start, value);
    return start + 1;
  }
  public int setNormalParams(int start, PreparedStatement pst) throws Exception {
    ArrayList<Table<T>.TableField> normalFields = table.getNoramlFields();
    final int size = normalFields.size();
    for (int index = 0; index < size; ++index) {
      Table<T>.TableField tableField = normalFields.get(index);
      Object value = getFieldValue(tableField);
      value = toDBValue(tableField, value);
      pst.setObject(start + index, value);
    }
    return start + size;
  }

就是根据表结构描述，通过反射获取对应字段的值然后设置。

 private Object getFieldValue(Table<T>.TableField tableField) throws Exception {
    Field field = object.getClass().getDeclaredField(tableField.fieldName);
    return field.get(object);
  }

toDBValue作用是将Java逻辑类型转成对应数据库类型，比如时间，在逻辑里是Long，而数据库类型是Timestamp。

 private Object toDBValue(Table<T>.TableField tableField, Object value) {
    if (tableField.type == TableField.TYPE_TIMESTAMP) {
      value = new Timestamp((long) value);
    }
    return value;
  }

以设置update SQL参数为例：

 public void setUpdateParams(PreparedStatement pst) throws Exception {
    final int start = setNormalParams(1, pst);
    setPrimaryParams(start, pst);
  }

之后执行该SQL语句就可以了。如果是select语句还会返回结果集（ResultSet），从结果集自动生成逻辑对象原理类似，算是一个逆过程，详细参看文末代码。

下面给出一个使用的完整示例：

private static final Table<UserData> udTable = new Table<UserData>();
...
udTable.load("user.xml");
...
public static boolean updateUserData(UserData userData) {
    boolean result = false;
    Record<UserData> record = udTable.createRecord();
    record.setObject(userData);
    PreparedStatement pst = null;
    try {
      String sql = udTable.getUpdateSql();
      pst = DbUtil.openConnection().prepareStatement(sql);
      record.setUpdateParams(pst);
      result = pst.executeUpdate() > 0;
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      DbUtil.closeConnection(null, pst);
    }
    return result;
  }

代码封装得很简易，有更多需求可据此改进。

您可能感兴趣的文章:

Java CAS操作与Unsafe类详解
这篇文章主要介绍了Java CAS操作与Unsafe类的相关资料，帮助大家更好的理解和学习使用Java，感兴趣的朋友可以了解下
2021-02-02
SpringBoot2零基础到精通之数据库专项精讲
SpringBoot是一种整合Spring技术栈的方式(或者说是框架)，同时也是简化Spring的一种快速开发的脚手架，本篇我们来学习如何连接数据库进行操作
2022-03-03
Java核心编程之文件随机读写类RandomAccessFile详解
这篇文章主要为大家详细介绍了Java核心编程之文件随机读写类RandomAccessFile，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-08-08
Monaco Editor实现sql和java代码提示实现示例
这篇文章主要为大家介绍了Monaco Editor代码提示sql和java实现示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-08-08
Java Stream常用方法合集(超详细)
Stream API 提供了一种更为简洁高效的的方式来处理集合数据, 可读性较高, 所以本文为大家整理了Java Stream中的常用方法，希望对大家有所帮助
2023-07-07
Spring-retry实现循环重试功能
这篇文章主要介绍了Spring-retry 优雅的实现循环重试功能,通过@Retryable注解，优雅的实现循环重试功能，需要的朋友可以参考下
2023-07-07
SpringBoot整合Retry实现错误重试过程逐步介绍
重试的使用场景比较多，比如调用远程服务时，由于网络或者服务端响应慢导致调用超时，此时可以多重试几次。用定时任务也可以实现重试的效果，但比较麻烦，用Spring Retry的话一个注解搞定所有，感兴趣的可以了解一下
2023-02-02
Java之ThreadLocal使用常见和方式案例讲解
这篇文章主要介绍了Java之ThreadLocal使用常见和方式案例讲解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
2021-08-08
SpringBoot实现PPT格式文件上传并在线预览功能
本文介绍SpringBoot实现PPT格式文件上传并在线预览功能，通过上传接口，可在C盘的tempfile目录下找到上传的文件，预览时会在同级目录下创建一个相同文件名后缀为pdf的文件，每次预览会先查找文件是否存在，存在则直接预览，不存在则会走上面的处理,需要的朋友可以参考下
2022-02-02
Java NIO 中 Selector 解析
这篇文章主要介绍了Java NIO 中 Selector，Selector即选择器，选择器提供选择执行已经就绪的任务的能力即为翻译为多路复用，下面文章对Selector详细介绍内容，需要的小伙伴可以参考一下
2022-02-02