• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java SQLInsertClause类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.querydsl.sql.dml.SQLInsertClause的典型用法代码示例。如果您正苦于以下问题:Java SQLInsertClause类的具体用法?Java SQLInsertClause怎么用?Java SQLInsertClause使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



SQLInsertClause类属于com.querydsl.sql.dml包,在下文中一共展示了SQLInsertClause类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: insertFeatureOfInterest

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertFeatureOfInterest(FeatureOfInterest foi) throws NoSuchEntityException {
    // No linked entities to check first.
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QFeatures qfoi = QFeatures.features;
    SQLInsertClause insert = qFactory.insert(qfoi);
    insert.set(qfoi.name, foi.getName());
    insert.set(qfoi.description, foi.getDescription());
    insert.set(qfoi.properties, objectToJson(foi.getProperties()));

    String encodingType = foi.getEncodingType();
    insert.set(qfoi.encodingType, encodingType);
    insertGeometry(insert, qfoi.feature, qfoi.geom, encodingType, foi.getFeature());

    UUID generatedId = insert.executeWithKey(qfoi.id);
    LOGGER.info("Inserted FeatureOfInterest. Created id = {}.", generatedId);
    foi.setId(new UuidId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:19,代码来源:EntityInserter.java


示例2: insertSensor

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertSensor(Sensor s) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QSensors qs = QSensors.sensors;
    SQLInsertClause insert = qFactory.insert(qs);
    insert.set(qs.name, s.getName());
    insert.set(qs.description, s.getDescription());
    insert.set(qs.encodingType, s.getEncodingType());
    // TODO: Check metadata serialisation.
    insert.set(qs.metadata, s.getMetadata().toString());
    insert.set(qs.properties, objectToJson(s.getProperties()));

    UUID generatedId = insert.executeWithKey(qs.id);
    LOGGER.info("Inserted Sensor. Created id = {}.", generatedId);
    s.setId(new UuidId(generatedId));

    // Create new datastreams, if any.
    for (Datastream ds : s.getDatastreams()) {
        ds.setSensor(new SensorBuilder().setId(s.getId()).build());
        ds.complete();
        pm.insert(ds);
    }

    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:25,代码来源:EntityInserter.java


示例3: insertFeatureOfInterest

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertFeatureOfInterest(FeatureOfInterest foi) throws NoSuchEntityException {
    // No linked entities to check first.
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QFeatures qfoi = QFeatures.features;
    SQLInsertClause insert = qFactory.insert(qfoi);
    insert.set(qfoi.name, foi.getName());
    insert.set(qfoi.description, foi.getDescription());
    insert.set(qfoi.properties, objectToJson(foi.getProperties()));

    String encodingType = foi.getEncodingType();
    insert.set(qfoi.encodingType, encodingType);
    insertGeometry(insert, qfoi.feature, qfoi.geom, encodingType, foi.getFeature());

    Long generatedId = insert.executeWithKey(qfoi.id);
    LOGGER.info("Inserted FeatureOfInterest. Created id = {}.", generatedId);
    foi.setId(new LongId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:19,代码来源:EntityInserter.java


示例4: insertSensor

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertSensor(Sensor s) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QSensors qs = QSensors.sensors;
    SQLInsertClause insert = qFactory.insert(qs);
    insert.set(qs.name, s.getName());
    insert.set(qs.description, s.getDescription());
    insert.set(qs.encodingType, s.getEncodingType());
    // TODO: Check metadata serialisation.
    insert.set(qs.metadata, s.getMetadata().toString());
    insert.set(qs.properties, objectToJson(s.getProperties()));

    Long generatedId = insert.executeWithKey(qs.id);
    LOGGER.info("Inserted Sensor. Created id = {}.", generatedId);
    s.setId(new LongId(generatedId));

    // Create new datastreams, if any.
    for (Datastream ds : s.getDatastreams()) {
        ds.setSensor(new SensorBuilder().setId(s.getId()).build());
        ds.complete();
        pm.insert(ds);
    }

    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:25,代码来源:EntityInserter.java


示例5: insertFeatureOfInterest

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertFeatureOfInterest(FeatureOfInterest foi) throws NoSuchEntityException {
    // No linked entities to check first.
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QFeatures qfoi = QFeatures.features;
    SQLInsertClause insert = qFactory.insert(qfoi);
    insert.set(qfoi.name, foi.getName());
    insert.set(qfoi.description, foi.getDescription());
    insert.set(qfoi.properties, objectToJson(foi.getProperties()));

    String encodingType = foi.getEncodingType();
    insert.set(qfoi.encodingType, encodingType);
    insertGeometry(insert, qfoi.feature, qfoi.geom, encodingType, foi.getFeature());

    String generatedId = insert.executeWithKey(qfoi.id);
    LOGGER.info("Inserted FeatureOfInterest. Created id = {}.", generatedId);
    foi.setId(new StringId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:19,代码来源:EntityInserter.java


示例6: insertSensor

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertSensor(Sensor s) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QSensors qs = QSensors.sensors;
    SQLInsertClause insert = qFactory.insert(qs);
    insert.set(qs.name, s.getName());
    insert.set(qs.description, s.getDescription());
    insert.set(qs.encodingType, s.getEncodingType());
    // TODO: Check metadata serialisation.
    insert.set(qs.metadata, s.getMetadata().toString());
    insert.set(qs.properties, objectToJson(s.getProperties()));

    String generatedId = insert.executeWithKey(qs.id);
    LOGGER.info("Inserted Sensor. Created id = {}.", generatedId);
    s.setId(new StringId(generatedId));

    // Create new datastreams, if any.
    for (Datastream ds : s.getDatastreams()) {
        ds.setSensor(new SensorBuilder().setId(s.getId()).build());
        ds.complete();
        pm.insert(ds);
    }

    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:25,代码来源:EntityInserter.java


示例7: saveNew

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private void saveNew(final Long userId, final Date startDate,
    final Date endDateExcluded, final long amountInSeconds, final String description) {

  transactionTemplate.execute(() -> {
    return querydslSupport.execute((connection, configuration) -> {

      QUserHolidayAmount qUserHolidayAmount = QUserHolidayAmount.userHolidayAmount;

      long dateRangeId = new DateRangeUtil(connection, configuration).createDateRange(startDate,
          endDateExcluded);

      new SQLInsertClause(connection, configuration, qUserHolidayAmount)
          .set(qUserHolidayAmount.userId, userId)
          .set(qUserHolidayAmount.dateRangeId, dateRangeId)
          .set(qUserHolidayAmount.amount, amountInSeconds)
          .set(qUserHolidayAmount.description, description).execute();
      return null;
    });
  });

}
 
开发者ID:everit-org,项目名称:jira-hr-admin,代码行数:22,代码来源:UserHolidayAmountServlet.java


示例8: save

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private void save(final long schemeId, final String userName, final Date startDate,
    final Date endDateExcluded) {
  transactionTemplate.execute(() -> querydslSupport.execute((connection, configuration) -> {
    QCwdUser qCwdUser = QCwdUser.cwdUser;
    Long userId = new SQLQuery<Long>(connection, configuration)
        .select(qCwdUser.id)
        .from(qCwdUser)
        .where(qCwdUser.userName.eq(userName)).fetchOne();

    Long dateRangeId =
        new DateRangeUtil(connection, configuration).createDateRange(startDate, endDateExcluded);

    new SQLInsertClause(connection, configuration,
        qUserSchemeEntityParameter.userSchemeEntityPath)
            .set(qUserSchemeEntityParameter.dateRangeId, dateRangeId)
            .set(qUserSchemeEntityParameter.userId, userId)
            .set(qUserSchemeEntityParameter.userSchemeSchemeId, schemeId).execute();

    return null;
  }));
}
 
开发者ID:everit-org,项目名称:jira-hr-admin,代码行数:22,代码来源:SchemeUsersComponent.java


示例9: savePublicHoliday

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private void savePublicHoliday(final long schemeId, final Date date, final Date replacementDate,
    final String description) {

  querydslSupport.execute((connection, configuration) -> {
    QPublicHoliday qPublicHoliday = QPublicHoliday.publicHoliday;
    SQLInsertClause insertClause = new SQLInsertClause(connection, configuration, qPublicHoliday)
        .set(qPublicHoliday.date, date);
    if (replacementDate != null) {
      insertClause.set(qPublicHoliday.replacementDate, replacementDate);
    }
    if (description != null && !"".equals(description.trim())) {
      insertClause.set(qPublicHoliday.description, description);
    }
    insertClause.set(qPublicHoliday.holidaySchemeId, schemeId);
    insertClause.execute();
    return null;
  });
}
 
开发者ID:everit-org,项目名称:jira-hr-admin,代码行数:19,代码来源:HolidaySchemesServlet.java


示例10: insertFacility

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
@TransactionalWrite
public long insertFacility(Facility facility, long facilityId) {
    checkNotNull(facility, "facility");
    facility.normalize();

    SQLInsertClause insert = insertFacility();
    insert.set(qFacility.id, facilityId);
    populate(facility, insert);
    insert.execute();

    insertAliases(facilityId, facility.aliases);
    insertPorts(facilityId, facility.ports);
    updateServices(facilityId, facility.services);
    updatePaymentMethods(facilityId, facility.paymentInfo.paymentMethods);
    insertPricing(facilityId, facility.pricingMethod.getPricing(facility));
    insertUnavailableCapacity(facilityId, facility.unavailableCapacities);

    // History updated
    final DateTime currentDate = DateTime.now();
    facilityHistoryRepository.updateStatusHistory(currentDate, facilityId, facility.status, facility.statusDescription);
    facilityHistoryRepository.updateCapacityHistory(currentDate, facilityId, facility.builtCapacity, facility.unavailableCapacities);

    return facilityId;
}
 
开发者ID:HSLdevcom,项目名称:parkandrideAPI,代码行数:25,代码来源:FacilityDao.java


示例11: insertPricing

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private void insertPricing(long facilityId, List<Pricing> pricing) {
    if (pricing != null && !pricing.isEmpty()) {
        SQLInsertClause insert = queryFactory.insert(qPricing);
        for (Pricing price : pricing) {
            insert.set(qPricing.facilityId, facilityId)
                    .set(qPricing.capacityType, price.capacityType)
                    .set(qPricing.usage, price.usage)
                    .set(qPricing.maxCapacity, price.maxCapacity)
                    .set(qPricing.dayType, price.dayType)
                    .set(qPricing.fromTime, price.time.from)
                    .set(qPricing.untilTime, price.time.until);
            pricingPriceMapping.populate(price.price, insert);
            insert.addBatch();
        }
        insert.execute();
    }
}
 
开发者ID:HSLdevcom,项目名称:parkandrideAPI,代码行数:18,代码来源:FacilityDao.java


示例12: insertUtilizations

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
@TransactionalWrite
@Override
public void insertUtilizations(List<Utilization> utilizations) {
    if (utilizations.isEmpty()) {
        return;
    }
    SQLInsertClause insertBatch = queryFactory.insert(qUtilization);
    utilizations.forEach(u -> {
        insertBatch.set(qUtilization.facilityId, u.facilityId);
        insertBatch.set(qUtilization.capacityType, u.capacityType);
        insertBatch.set(qUtilization.usage, u.usage);
        insertBatch.set(qUtilization.ts, u.timestamp);
        insertBatch.set(qUtilization.spacesAvailable, u.spacesAvailable);
        insertBatch.set(qUtilization.capacity, u.capacity);
        insertBatch.addBatch();
    });
    insertBatch.execute();
}
 
开发者ID:HSLdevcom,项目名称:parkandrideAPI,代码行数:19,代码来源:UtilizationDao.java


示例13: savePredictionHistory

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private void savePredictionHistory(Long predictorId, DateTime start, List<Prediction> predictions) {
    if (predictions.isEmpty()) {
        return;
    }
    SQLInsertClause insert = queryFactory.insert(qPredictionHistory);
    predictions.forEach(p -> insert
            .set(qPredictionHistory.predictorId, predictorId)
            .set(qPredictionHistory.forecastDistanceInMinutes, ((int) new Duration(start, p.timestamp).getStandardMinutes()))
            .set(qPredictionHistory.ts, p.timestamp)
            .set(qPredictionHistory.spacesAvailable, p.spacesAvailable)
            .addBatch());
    try {
        insert.execute();
    } catch (QueryException e) {
        // XXX: upsert would be a better way to ignore primary key conflicts, but this shall do for now
        log.error("Failed save prediction history for predictor " + predictorId, e);
    }
}
 
开发者ID:HSLdevcom,项目名称:parkandrideAPI,代码行数:19,代码来源:PredictionDao.java


示例14: insertHistoricalLocation

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertHistoricalLocation(HistoricalLocation h) throws NoSuchEntityException, IncompleteEntityException {
    Thing t = h.getThing();
    entityExistsOrCreate(t);

    SQLQueryFactory qFactory = pm.createQueryFactory();
    QHistLocations qhl = QHistLocations.histLocations;
    SQLInsertClause insert = qFactory.insert(qhl);
    insert.set(qhl.time, new Timestamp(h.getTime().getDateTime().getMillis()));
    insert.set(qhl.thingId, (UUID) h.getThing().getId().getValue());

    UUID generatedId = insert.executeWithKey(qhl.id);
    LOGGER.info("Inserted HistoricalLocation. Created id = {}.", generatedId);
    h.setId(new UuidId(generatedId));

    EntitySet<Location> locations = h.getLocations();
    for (Location l : locations) {
        entityExistsOrCreate(l);
        UUID lId = (UUID) l.getId().getValue();
        QLocationsHistLocations qlhl = QLocationsHistLocations.locationsHistLocations;
        insert = qFactory.insert(qlhl);
        insert.set(qlhl.histLocationId, generatedId);
        insert.set(qlhl.locationId, lId);
        insert.execute();
        LOGGER.debug("Linked Location {} to HistoricalLocation {}.", lId, generatedId);
    }
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:28,代码来源:EntityInserter.java


示例15: insertObservedProperty

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertObservedProperty(ObservedProperty op) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QObsProperties qop = QObsProperties.obsProperties;
    SQLInsertClause insert = qFactory.insert(qop);
    insert.set(qop.definition, op.getDefinition());
    insert.set(qop.name, op.getName());
    insert.set(qop.description, op.getDescription());
    insert.set(qop.properties, objectToJson(op.getProperties()));

    UUID generatedId = insert.executeWithKey(qop.id);
    LOGGER.info("Inserted ObservedProperty. Created id = {}.", generatedId);
    op.setId(new UuidId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:15,代码来源:EntityInserter.java


示例16: insertHistoricalLocation

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertHistoricalLocation(HistoricalLocation h) throws NoSuchEntityException, IncompleteEntityException {
    Thing t = h.getThing();
    entityExistsOrCreate(t);

    SQLQueryFactory qFactory = pm.createQueryFactory();
    QHistLocations qhl = QHistLocations.histLocations;
    SQLInsertClause insert = qFactory.insert(qhl);
    insert.set(qhl.time, new Timestamp(h.getTime().getDateTime().getMillis()));
    insert.set(qhl.thingId, (Long) h.getThing().getId().getValue());

    Long generatedId = insert.executeWithKey(qhl.id);
    LOGGER.info("Inserted HistoricalLocation. Created id = {}.", generatedId);
    h.setId(new LongId(generatedId));

    EntitySet<Location> locations = h.getLocations();
    for (Location l : locations) {
        entityExistsOrCreate(l);
        Long lId = (Long) l.getId().getValue();
        QLocationsHistLocations qlhl = QLocationsHistLocations.locationsHistLocations;
        insert = qFactory.insert(qlhl);
        insert.set(qlhl.histLocationId, generatedId);
        insert.set(qlhl.locationId, lId);
        insert.execute();
        LOGGER.debug("Linked Location {} to HistoricalLocation {}.", lId, generatedId);
    }
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:28,代码来源:EntityInserter.java


示例17: insertObservedProperty

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertObservedProperty(ObservedProperty op) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QObsProperties qop = QObsProperties.obsProperties;
    SQLInsertClause insert = qFactory.insert(qop);
    insert.set(qop.definition, op.getDefinition());
    insert.set(qop.name, op.getName());
    insert.set(qop.description, op.getDescription());
    insert.set(qop.properties, objectToJson(op.getProperties()));

    Long generatedId = insert.executeWithKey(qop.id);
    LOGGER.info("Inserted ObservedProperty. Created id = {}.", generatedId);
    op.setId(new LongId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:15,代码来源:EntityInserter.java


示例18: insertHistoricalLocation

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertHistoricalLocation(HistoricalLocation h) throws NoSuchEntityException, IncompleteEntityException {
    Thing t = h.getThing();
    entityExistsOrCreate(t);

    SQLQueryFactory qFactory = pm.createQueryFactory();
    QHistLocations qhl = QHistLocations.histLocations;
    SQLInsertClause insert = qFactory.insert(qhl);
    insert.set(qhl.time, new Timestamp(h.getTime().getDateTime().getMillis()));
    insert.set(qhl.thingId, (String) h.getThing().getId().getValue());

    String generatedId = insert.executeWithKey(qhl.id);
    LOGGER.info("Inserted HistoricalLocation. Created id = {}.", generatedId);
    h.setId(new StringId(generatedId));

    EntitySet<Location> locations = h.getLocations();
    for (Location l : locations) {
        entityExistsOrCreate(l);
        String lId = (String) l.getId().getValue();
        QLocationsHistLocations qlhl = QLocationsHistLocations.locationsHistLocations;
        insert = qFactory.insert(qlhl);
        insert.set(qlhl.histLocationId, generatedId);
        insert.set(qlhl.locationId, lId);
        insert.execute();
        LOGGER.debug("Linked Location {} to HistoricalLocation {}.", lId, generatedId);
    }
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:28,代码来源:EntityInserter.java


示例19: insertObservedProperty

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
public boolean insertObservedProperty(ObservedProperty op) throws NoSuchEntityException, IncompleteEntityException {
    SQLQueryFactory qFactory = pm.createQueryFactory();
    QObsProperties qop = QObsProperties.obsProperties;
    SQLInsertClause insert = qFactory.insert(qop);
    insert.set(qop.definition, op.getDefinition());
    insert.set(qop.name, op.getName());
    insert.set(qop.description, op.getDescription());
    insert.set(qop.properties, objectToJson(op.getProperties()));

    String generatedId = insert.executeWithKey(qop.id);
    LOGGER.info("Inserted ObservedProperty. Created id = {}.", generatedId);
    op.setId(new StringId(generatedId));
    return true;
}
 
开发者ID:FraunhoferIOSB,项目名称:SensorThingsServer,代码行数:15,代码来源:EntityInserter.java


示例20: saveScheme

import com.querydsl.sql.dml.SQLInsertClause; //导入依赖的package包/类
private long saveScheme(final String schemeName) {
  return querydslSupport.execute((connection, configuration) -> {
    QWorkScheme qWorkScheme = QWorkScheme.workScheme;
    return new SQLInsertClause(connection, configuration, qWorkScheme)
        .set(qWorkScheme.name, schemeName)
        .set(qWorkScheme.scope, WORK_SCHEME_SCOPE_GLOBAL)
        .executeWithKey(qWorkScheme.workSchemeId);
  });
}
 
开发者ID:everit-org,项目名称:jira-hr-admin,代码行数:10,代码来源:WorkSchemesServlet.java



注:本文中的com.querydsl.sql.dml.SQLInsertClause类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ByteSourceFile类代码示例发布时间:2022-05-22
下一篇:
Java TimerDeclarationImpl类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap