github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#9442] Support sequence flags in MariaDBDatabase

Browse Source
This commit is contained in:
Knut Wannheden 2019-12-04 08:44:10 +01:00
parent 7497d0006c
commit f0950e0779
1 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
jOOQ-meta/src/main/java/org/jooq/meta/mariadb/MariaDBDatabase.java
View File

@ -38,11 +38,16 @@
package org.jooq.meta.mariadb;
import static org.jooq.impl.DSL.field;
import static org.jooq.impl.DSL.inline;
import static org.jooq.impl.DSL.nullif;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.jooq.DSLContext;
import org.jooq.Field;
import org.jooq.Record;
import org.jooq.SQLDialect;
import org.jooq.impl.DSL;
@ -59,6 +64,9 @@ import org.jooq.util.mariadb.MariaDBDataType;
*/
public class MariaDBDatabase extends MySQLDatabase {
private static final long DEFAULT_SEQUENCE_MAXVALUE = Long.MAX_VALUE - 1;
private static final long DEFAULT_SEQUENCE_CACHE = 1000L;
@Override
protected DSLContext create0() {
return DSL.using(getConnection(), SQLDialect.MARIADB);
@ -83,7 +91,29 @@ public class MariaDBDatabase extends MySQLDatabase {
MariaDBDataType.BIGINT.getTypeName()
);
result.add(new DefaultSequenceDefinition(schema, name, type));
Field<Long> startWith = nullif(field("start_value", Long.class), inline(1L));
Field<Long> incrementBy = nullif(field("increment", Long.class), inline(1L));
Field<Long> minValue = inline(field("minimum_value", Long.class), inline(1L));
Field<Long> maxValue = nullif(field("maximum_value", Long.class), inline(DEFAULT_SEQUENCE_MAXVALUE));
Field<Boolean> cycle = field("cycle_option", Boolean.class);
Field<Long> cache = nullif(field("cache_size", Long.class), inline(DEFAULT_SEQUENCE_CACHE));
Record flagsRecord = create()
.select(startWith, incrementBy, minValue, maxValue, cycle, cache)
.from(DSL.name(schema.getName(), name))
.fetchOne();
result.add(new DefaultSequenceDefinition(
schema,
name,
type,
null,
flagsRecord.get(startWith),
flagsRecord.get(incrementBy),
flagsRecord.get(minValue),
flagsRecord.get(maxValue),
flagsRecord.get(cycle),
flagsRecord.get(cache)
));
}
}