org.jooq.Table.getPrimaryKey()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(112)

本文整理了Java中org.jooq.Table.getPrimaryKey()方法的一些代码示例，展示了Table.getPrimaryKey()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Table.getPrimaryKey()方法的具体详情如下：
包路径：org.jooq.Table
类名称：Table
方法名：getPrimaryKey

Table.getPrimaryKey介绍

[英]Retrieve the table's primary key
[中]检索表的主键

代码示例

代码示例来源：origin: org.jooq/jooq

@Override
public final LoaderImpl<R> onDuplicateKeyUpdate() {
  if (table.getPrimaryKey() == null) {
    throw new IllegalStateException("ON DUPLICATE KEY UPDATE only works on tables with explicit primary keys. Table is not updatable : " + table);
  }
  onDuplicate = ON_DUPLICATE_KEY_UPDATE;
  return this;
}

代码示例来源：origin: com.ning.billing/killbill-osgi-bundles-analytics

@Override
public final LoaderImpl<R> onDuplicateKeyIgnore() {
  if (table.getPrimaryKey() == null) {
    throw new IllegalStateException("ON DUPLICATE KEY IGNORE only works on tables with explicit primary keys. Table is not updatable : " + table);
  }
  onDuplicate = ON_DUPLICATE_KEY_IGNORE;
  return this;
}

代码示例来源：origin: org.jooq/jooq

@Override
public final LoaderImpl<R> onDuplicateKeyIgnore() {
  if (table.getPrimaryKey() == null) {
    throw new IllegalStateException("ON DUPLICATE KEY IGNORE only works on tables with explicit primary keys. Table is not updatable : " + table);
  }
  onDuplicate = ON_DUPLICATE_KEY_IGNORE;
  return this;
}

代码示例来源：origin: org.jooq/jooq

@Override
  public final List<UniqueKey<?>> getPrimaryKeys() {
    List<UniqueKey<?>> result = new ArrayList<UniqueKey<?>>();

    for (Table<?> table : tables)
      if (table.getPrimaryKey() != null)
        result.add(table.getPrimaryKey());

    return result;
  }
}

代码示例来源：origin: com.ning.billing/killbill-osgi-bundles-analytics

@Override
public final LoaderImpl<R> onDuplicateKeyUpdate() {
  if (table.getPrimaryKey() == null) {
    throw new IllegalStateException("ON DUPLICATE KEY UPDATE only works on tables with explicit primary keys. Table is not updatable : " + table);
  }
  onDuplicate = ON_DUPLICATE_KEY_UPDATE;
  return this;
}

代码示例来源：origin: org.jooq/jooq

@Override
  public final List<UniqueKey<?>> getPrimaryKeys() {
    List<UniqueKey<?>> result = new ArrayList<UniqueKey<?>>();

    for (Schema schema : schemas)
      for (Table<?> table : schema.getTables())
        if (table.getPrimaryKey() != null)
          result.add(table.getPrimaryKey());

    return result;
  }
}

代码示例来源：origin: org.jooq/jooq

@Override
public final List<UniqueKey<?>> getPrimaryKeys() {
  List<UniqueKey<?>> result = new ArrayList<UniqueKey<?>>();
  for (Table<?> table : getTables()) {
    UniqueKey<?> pk = table.getPrimaryKey();
    if (pk != null)
      result.add(pk);
  }
  return result;
}

代码示例来源：origin: com.ning.billing/killbill-osgi-bundles-analytics

@Override
public final List<UniqueKey<?>> getPrimaryKeys() {
  List<UniqueKey<?>> result = new ArrayList<UniqueKey<?>>();
  for (Table<?> table : getTables()) {
    UniqueKey<?> pk = table.getPrimaryKey();
    if (pk != null) {
      result.add(pk);
    }
  }
  return result;
}

代码示例来源：origin: org.jooq/jooq

@Override
  public final List<UniqueKey<?>> getPrimaryKeys() {
    List<UniqueKey<?>> result = new ArrayList<UniqueKey<?>>();

    for (Catalog catalog : catalogs)
      for (Schema schema : catalog.getSchemas())
        for (Table<?> table : schema.getTables())
          if (table.getPrimaryKey() != null)
            result.add(table.getPrimaryKey());

    return result;
  }
}

代码示例来源：origin: k55k32/cms-admin-end

@SuppressWarnings("unchecked")
private Field<ID> pk() {
  UniqueKey<?> uk = table.getPrimaryKey();
  Field<?>[] fs = uk.getFieldsArray();
  return (Field<ID>) fs[0];
}

代码示例来源：origin: cn.vertxup/vertx-up

private <T> T skipPrimaryKey(final T entity) {
  final Table<?> tableField = Ut.field(this.vertxDAO, "table");
  final UniqueKey key = tableField.getPrimaryKey();
  key.getFields().stream().map(item -> ((TableField) item).getName())
      .filter(this.revert::containsKey)
      .map(this.revert::get)
      .forEach(item -> Ut.field(entity, item.toString(), null));
  return entity;
}

代码示例来源：origin: silentbalanceyh/vertx-zero

private <T> T skipPrimaryKey(final T entity) {
  final Table<?> tableField = Ut.field(this.vertxDAO, "table");
  final UniqueKey key = tableField.getPrimaryKey();
  key.getFields().stream().map(item -> ((TableField) item).getName())
      .filter(this.revert::containsKey)
      .map(this.revert::get)
      .forEach(item -> Ut.field(entity, item.toString(), null));
  return entity;
}

代码示例来源：origin: org.jooq/jooq

@SuppressWarnings("unchecked")
protected /* non-final */ T compositeKeyRecord(Object... values) {
  UniqueKey<R> key = table.getPrimaryKey();
  if (key == null)
    return null;
  TableField<R, Object>[] fields = (TableField<R, Object>[]) key.getFieldsArray();
  Record result = DSL.using(configuration)
            .newRecord(fields);
  for (int i = 0; i < values.length; i++)
    result.set(fields[i], fields[i].getDataType().convert(values[i]));
  return (T) result;
}

代码示例来源：origin: org.jooq/jooq

@Override
public <R extends UpdatableRecord<R>> int executeDelete(R record) {
  DeleteQuery<R> delete = deleteQuery(record.getTable());
  Tools.addConditions(delete, record, record.getTable().getPrimaryKey().getFieldsArray());
  return delete.execute();
}

代码示例来源：origin: com.ning.billing/killbill-osgi-bundles-analytics

@Override
public <R extends UpdatableRecord<R>> int executeDelete(R record) {
  DeleteQuery<R> delete = deleteQuery(record.getTable());
  Utils.addConditions(delete, record, record.getTable().getPrimaryKey().getFieldsArray());
  return delete.execute();
}

代码示例来源：origin: org.jooq/jooq

@Override
public <R extends UpdatableRecord<R>> int executeUpdate(R record) {
  UpdateQuery<R> update = updateQuery(record.getTable());
  Tools.addConditions(update, record, record.getTable().getPrimaryKey().getFieldsArray());
  update.setRecord(record);
  return update.execute();
}

代码示例来源：origin: jklingsporn/vertx-jooq

public INSERT_RETURNING insertReturningPrimary(P object){
  UniqueKey<?> key = getTable().getPrimaryKey();
  //usually key shouldn't be null because DAO generation is omitted in such cases
  Objects.requireNonNull(key,()->"No primary key");
  return queryExecutor().insertReturning(
      dslContext -> dslContext.insertInto(getTable()).set(newRecord(dslContext, object)).returning(key.getFields()),
      keyConverter());
}

代码示例来源：origin: jklingsporn/vertx-jooq

@SuppressWarnings("unchecked")
protected /* non-final */ T compositeKeyRecord(Object... values) {
  UniqueKey<R> key = table.getPrimaryKey();
  if (key == null)
    return null;
  TableField<R, Object>[] fields = (TableField<R, Object>[]) key.getFieldsArray();
  Record result = DSL.using(queryExecutor.configuration())
      .newRecord(fields);
  for (int i = 0; i < values.length; i++)
    result.set(fields[i], fields[i].getDataType().convert(values[i]));
  return (T) result;
}

代码示例来源：origin: io.github.jklingsporn/vertx-jooq-shared-async

@Override
  public INSERT_RETURNING insertReturningPrimary(P object) {
    return queryExecutor().insertReturning(dslContext -> dslContext
            .insertInto(getTable())
            .set(newRecord(dslContext, object))
            .returning(getTable().getPrimaryKey().getFieldsArray()),
        keyConverter);
  }
}

代码示例来源：origin: jklingsporn/vertx-jooq

@Override
  public INSERT_RETURNING insertReturningPrimary(P object) {
    return queryExecutor().insertReturning(dslContext -> dslContext
            .insertInto(getTable())
            .set(newRecord(dslContext, object))
            .returning(getTable().getPrimaryKey().getFieldsArray()),
        keyConverter());
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Table

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com