public interface PersistenceService<T> {
    /**
     * 保存对象到数据库
     * @param objects 对象列表
     */
    void save(List<T> objects);

    /**
     * 从数据库取出对象列表
     * @param clazz 对象类
     * @param Objects 对象列表
     */
    void get(Class<T> clazz, List<T> Objects);
}

public class PersistenceServiceImpl<T> implements PersistenceService<T> {
    // 数据库连接池
    private static final DatabaseConfig DATA_SOURCE = new DatabaseConfig();

    /**
     * 保存对象列表到数据库
     *
     * @param objects 对象列表
     */
    @Override
    public void save(List<T> objects) {
        if (objects == null || objects.size() == 0) {
            return;
        }
        // 利用反射获取对象的类名，作为数据表名，但不要获取父类的类名
        String tableName = objects.get(0).getClass().getSimpleName().toLowerCase();
        // 利用反射获取对象的字段列表
        Field[] fields = objects.get(0).getClass().getDeclaredFields();
        String[] fieldNames = new String[fields.length];
        for (int i = 0; i < fields.length; i++) {
            fieldNames[i] = fields[i].getName();
        }
        // 打印表名和字段列表
        System.out.println("tableName: " + tableName);
        System.out.println("fields: " + Arrays.toString(fieldNames));
        // 拼接SQL语句
        StringBuilder sql = new StringBuilder("INSERT INTO `" + tableName + "` (");
        for (String field : fieldNames) {
            sql.append(field).append(",");
        }
        sql.deleteCharAt(sql.length() - 1).append(") VALUES (");
        for (int i = 0; i < fields.length; i++) {
            sql.append("?,");
        }
        sql.deleteCharAt(sql.length() - 1).append(")");
        // 打印SQL语句
        System.out.println("SQL: " + sql);
        // 初始化PreparedStatement
        try (Connection conn = DATA_SOURCE.getConnection()) {
            conn.setAutoCommit(false);
            PreparedStatement pstmt = null;
            try {
                pstmt = conn.prepareStatement(sql.toString());
                // 遍历对象列表
                for (T object : objects) {
                    // 利用反射获取对象的字段值
                    for (int i = 0; i < fields.length; i++) {
                        fields[i].setAccessible(true);
                        Object content = fields[i].get(object);
                        pstmt.setObject(i + 1, content);
                    }
                    // 添加到批处理
                    pstmt.addBatch();
                }
                // 执行批处理
                pstmt.executeBatch();
                conn.commit();
            } catch (SQLException | IllegalAccessException e) {
                throw new RuntimeException(e);
            } finally {
                if (pstmt != null) {
                    try {
                        pstmt.close();
                    } catch (SQLException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 从数据库获取对象列表
     *
     * @param clazz   对象类
     * @param objects 对象列表
     */
    @Override
    public void get(Class<T> clazz, List<T> objects) {
        // 利用反射获取对象的类名，作为数据表名
        String tableName = clazz.getSimpleName().toLowerCase();
        // 利用反射获取对象的字段列表
        Field[] fields = clazz.getDeclaredFields();
        String[] fieldNames = new String[fields.length];
        for (int i = 0; i < fields.length; i++) {
            fieldNames[i] = fields[i].getName();
        }
        // 打印表名和字段列表
        System.out.println("tableName: " + tableName);
        System.out.println("fields: " + Arrays.toString(fieldNames));
        // 拼接SQL语句
        StringBuilder sql = new StringBuilder("SELECT ");
        for (String field : fieldNames) {
            sql.append(field).append(",");
        }
        sql.deleteCharAt(sql.length() - 1).append(" FROM ").append("`").append(tableName).append("`");
        // 打印SQL语句
        System.out.println("SQL: " + sql);
        // 初始化PreparedStatement
        try (Connection conn = DATA_SOURCE.getConnection();
             PreparedStatement pstmt = conn.prepareStatement(sql.toString())) {
            // 执行查询
            try (ResultSet rs = pstmt.executeQuery()) {
                // 遍历结果集
                while (rs.next()) {
                    // 利用反射创建对象
                    T object = clazz.newInstance();
                    // 利用反射设置对象的字段值
                    for (int i = 0; i < fields.length; i++) {
                        fields[i].setAccessible(true);
                        fields[i].set(object, rs.getObject(i + 1));
                    }
                    // 添加到对象列表
                    objects.add(object);
                }
            }
        } catch (SQLException | IllegalAccessException | InstantiationException e) {
            throw new RuntimeException(e);
        }
    }
}