, Однако я не могу воспроизвести это. Какую версию драйвера JDBC вы используете?
я есть таблица с первичным ключомid
, выберите, вставьте и удалите запросы, все работают из Java-программы, но запрос на обновление не работает, чтобы «вставить при повторном обновлении» (работает только тогда, когда запись не существует, когда запись существует, обновление не будет работать).
Все запросы подтверждены, и моя версия mariadb - 10.1.14.
Заранее благодарю за любую помощь!
Все запросы хорошо работают в MySQL.
схема таблицы+------------------+----------------------+------+-----+---------------------+-----------------------------+
| Field | Type | Null | Key | Default | Extra |
+------------------+----------------------+------+-----+---------------------+-----------------------------+
| id | int(10) unsigned | NO | PRI | NULL | |
| posng_valid_type | tinyint(3) unsigned | YES | | NULL | |
| longitude | double(9,6) | NO | | 0.000000 | |
| latitude | double(9,6) | NO | | 0.000000 | |
| heading | smallint(6) | NO | | 0 | |
| altitude | float(7,3) | NO | | 0.000 | |
| gps_speed | smallint(5) unsigned | NO | | 0 | |
| sample_time | timestamp | NO | | 0000-00-00 00:00:00 | |
| update_time | timestamp | NO | | CURRENT_TIMESTAMP | on update CURRENT_TIMESTAMP |
+------------------+----------------------+------+-----+---------------------+-----------------------------+
1. обновить запросupdate `status_position`
set `status_position`.`id` = 3007,
`status_position`.`posng_valid_type` = 0,
`status_position`.`longitude` = 121.1921,
`status_position`.`latitude` = 31.2797,
`status_position`.`heading` = -1,
`status_position`.`altitude` = 0.0,
`status_position`.`gps_speed` = 0,
`status_position`.`sample_time` = timestamp '2017-02-15 03:52:23.0'
where `status_position`.`id` = 3007;
2. обновление по дублирующему запросуinsert into `status_position` (
`id`,
`posng_valid_type`,
`longitude`,
`latitude`,
`heading`,
`altitude`,
`gps_speed`,
`sample_time`
) values (
2001,
0,
121.1921,
31.2797,
-1,
0.0,
0,
timestamp '2017-02-15 03:52:23.0'
) on duplicate key update
`status_position`.`id` = 2001,
`status_position`.`posng_valid_type` = 0,
`status_position`.`longitude` = 121.1921,
`status_position`.`latitude` = 31.2797,
`status_position`.`heading` = -1,
`status_position`.`altitude` = 0.0,
`status_position`.`gps_speed` = 0,
`status_position`.`sample_time` = timestamp '2017-02-15 03:52:23.0';
Java-код с JOOQ, который генерирует запрос 2public <R extends Record> void batchUpsertRecord(Table<R> table, List<R> records) throws PersistenceException {
Connection conn = ConnectionPoolManager.INSTANCE.getConnection();
try (DSLContext dslContext = DSL.using(conn, SQLDialect.MARIADB)) {
List<InsertQuery> insertQueryList = new ArrayList<>();
for (R record : records) {
InsertQuery<R> insert = dslContext.insertQuery(table);
insert.addRecord(record);
insert.onDuplicateKeyUpdate(true);
insert.addValuesForUpdate(mapOfChangedValues(record));
insertQueryList.add(insert);
}
dslContext.batch(insertQueryList).execute();
conn.commit();
} catch (SQLException e) {
logger.error("Failed to upsert record into table({}).", table.getName(), e);
} finally {
ConnectionPoolManager.INSTANCE.closeConnection(conn, logger);
}
}