主页 / 问题 / 603350
Accepted
Senior Pomidor
Asked:2020-12-14 15:04:14 +0000 UTC2020-12-14 15:04:14 +0000 UTC

Hibernate 和 Tibero 数据库

  • 772

实体 DB Tibero可以没有PK。将数据库实体映射到代码（通过数据库模式生成持久性映射）需要Hibernate.

当然，您可以读取 ResultSet 并进一步处理它，但这在读取时很方便，而在写入或更新数据库中的记录时，您将不得不实现您的自行车。

你有什么建议吗？是否有其他 ORM 系统可以在没有 PK 的情况下工作？

Ps 如果没有 PC，即使更新也无法完成，因为没有可以让您准确识别记录的唯一字段。Tibero 中的所有属性都可以为空，这意味着您可以有 N 个字段为空的记录。

база-данных

1 个回答

  1. Best Answer

    也许它会对某人有用......

    创建了一个注释来定义主键

    @Retention(RetentionPolicy.RUNTIME)
public @interface PrimaryKey {

}

@PrimaryKey
private BigDecimal id_Row;

    在每个班级注册地址

    public String getPath(){ return "s.table"; }

    我接收ResultSet并传递给填充类的方法

     /**
 * Load data from DB to collection by mapping fields from class type
 */
public Object loadObjectFromResultSet(Class classType, ResultSet resultSet) throws Exception
{
    ArrayList<Object> objectArrayList = new ArrayList<>();
    Object fieldValue;
    while(resultSet.next()) {
        Object typeOfFieldsClass = classType.newInstance();
        Field[] classFields = typeOfFieldsClass.getClass().getFields();
        for (Field field : classFields) {
            fieldValue = resultSet.getObject(field.getName());
            field.set(typeOfFieldsClass, fieldValue);
        }
        objectArrayList.add(typeOfFieldsClass);
    }
    return objectArrayList;
}

    回到List<MyEntityClass>我工作的地方，改变我需要的

     //Данный метод сохраняет все
public static <T> void saveAll(List<T> objects, DataBase db) throws ReflectiveOperationException {
        db.connectToTibero();
        for (T c : objects) {
            String qw = createQuery(c);
            System.out.println(qw);
            db.executeUpdate(qw);
        }
        db.executeUpdate("commit;");

    }

    private static String createQuery(Object c) throws ReflectiveOperationException {
        StringBuilder sb = new StringBuilder("UPDATE ");
        sb.append(getDbPath(c.getClass())).append(" set ");
        Object clazz = c;
        java.lang.reflect.Field[] fields = c.getClass().getFields();
        for (int i = 0; i < fields.length - 1; i++) {
            Object value = fields[i].get(clazz);
            if(value == null)
                value = "";
            sb.append(fields[i].getName()).append(" = '").append(value).append("', ");
        }
        if (fields.length > 1) {
            sb.append(fields[fields.length - 1].getName())
                .append(" = '")
                .append(fields[fields.length - 1].get(clazz))
                .append("' ");

            Field primField = Arrays.stream(fields)
                .filter(field -> field.isAnnotationPresent(PrimaryKey.class))
                .findFirst()
                .orElseThrow(() -> new NotFoundException("cannot found public field with annotation @PrimaryKey"));

            sb.append(" where " )
                .append(primField.getName())
                .append(" = '")
                .append(primField.get(clazz))
                .append("' ;");

            return sb.toString();
        } else {
            return null;
        }
/**
 * Get path for table from method declared in base class type
 *
 * @return string with table path
 */
private static String getDbPath(Class classType)
    throws ReflectiveOperationException {
    Object value = null;
    Object tmpObject = null;
    tmpObject = classType.newInstance();
    java.lang.reflect.Method method;
    if (tmpObject != null) {
        method = classType.getMethod("getPath");
        value = method.invoke(tmpObject);
    } else {
        throw new RuntimeException("Empty object");
    }
    return (String) value;
}
    • 0

相关问题