跳至主要內容

插入或者更新

xuejmnet大约 2 分钟

旧版本的Easy Query提供了只支持MySQL的onDuplicateKeyIgnoreonDuplicateKeyUpdate方法,只支持PostgreSQL的onConflictDoNothingonConflictDoUpdate方法。
这些方法都是用于设置重复插入策略的,它们已经过时了,在此不再讲述。

1.10.41+版本的Easy Query提供了更加强大的conflictThen方法,它用于插入或更新操作,它并不是简单的查询判断是否存在,如果不存在就更新,存在就更新或者忽略,而是实现了数据库对应的方言实现数据库自身的功能。它支持的数据库如下:

数据库名称包名是否支持
MySQLsql-mysql
Oraclesql-oracle
PostgresSQLsql-pgsql
SqlServersql-mssql
H2sql-h2
SQLitesql-sqlite
达梦damengsql-dameng
人大金仓KingbaseESsql-kingbase-es

conflictThen方法的第一个参数指定需要更新的字段,如果传入null则不进行更新,第二个参数指定用于判断对象是否存在所需要的字段,第二个参数如果不传则默认使用主键字段判断,支持多字段(MySQL不支持所以设置了也无效),conflictThen方法执行的大概过程是根据第二个参数指定的字段判断对象是否已存在,如果存在,则更新第一个参数指定的字段,否则执行插入操作,插入的是全部字段。

存在则更新

本例使用conflictThen方法,不传第二个参数,默认使用主键字段判断对象是否已存在,本例为存在则更新第一个参数指定的字段。

    @Test
    public void testOnConflictThenUpdate() {
        User user = easyEntityQuery.queryable(User.class).findNotNull(1);
        Date updateTime = new Date();
        user.setUpdateTime(updateTime);
        long rows = easyEntityQuery.insertable(user)
                .onConflictThen(o -> o.FETCHER.allFields())
                .executeRows();
        Assertions.assertTrue(rows > 0);

        user = easyEntityQuery.queryable(User.class).findNotNull(1);
        updateTime = new Date();
        user.setUpdateTime(updateTime);
        rows = easyEntityQuery.insertable(user)
                .onConflictThen(o -> o.FETCHER.updateTime())
                .executeRows();
        Assertions.assertTrue(rows > 0);
    }

不存在则插入

本例使用conflictThen方法,使用第二个参数传入主键字段来判断对象是否已存在,本例为不存在则插入全部字段。

    @Test
    public void testOnConflictThenInsert() {
        User user = new User();
        Date createTime = new Date();
        user.setName("新用户");
        user.setCreateTime(createTime);
        user.setVersion(1);
        user.setEnabled(true);
        long rows = easyEntityQuery.insertable(user)
                .onConflictThen(null, o -> o.FETCHER.id())
                .executeRows();
        Assertions.assertTrue(rows > 0);
    }
上次编辑于:
贡献者: Hoysing