com.j256.ormlite.dao.Dao.updateBuilder()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.8k)|赞(0)|评价(0)|浏览(231)

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

Dao.updateBuilder介绍

[英]Like #queryBuilder() but allows you to build an UPDATE statement. You can then call call UpdateBuilder#prepare() and pass the returned PreparedUpdate to #update(PreparedUpdate).
[中]类似于#queryBuilder(),但允许您构建UPDATE语句。然后可以调用UpdateBuilder#prepare()并将返回的PreparedUpdate传递给#update(PreparedUpdate)。

代码示例

代码示例来源:origin: j256/ormlite-core

  1. /**
  2. * @see Dao#updateBuilder()
  3. */
  4. @Override
  5. public UpdateBuilder<T, ID> updateBuilder() {
  6. return dao.updateBuilder();
  7. }

代码示例来源:origin: com.j256.ormlite/ormlite-core

  1. /**
  2. * @see Dao#updateBuilder()
  3. */
  4. @Override
  5. public UpdateBuilder<T, ID> updateBuilder() {
  6. return dao.updateBuilder();
  7. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. private void enableDisable(List<Integer> ids, boolean enabled) {
  2. try {
  3. UpdateBuilder<ForwardPayload, Integer> updateBuilder = this.getDao().updateBuilder();
  4. updateBuilder.updateColumnValue(ForwardPayload.KEY_ENABLED, enabled).where()
  5. .in(ForwardPayload.KEY_ID, ids);
  6. int updateCount = updateBuilder.update();
  7. _logger.debug("Updated rows count:{}", updateCount);
  8. } catch (SQLException ex) {
  9. _logger.error("Failed to update, Ids:{}", ids, ex);
  10. }
  11. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. @Override
  2. public void disableAllTriggered() {
  3. try {
  4. UpdateBuilder<RuleDefinitionTable, Integer> updateBuilder = getDao().updateBuilder();
  5. updateBuilder.updateColumnValue(RuleDefinitionTable.KEY_TRIGGERED, false).where()
  6. .eq(RuleDefinitionTable.KEY_TRIGGERED, true);
  7. Integer count = updateBuilder.update();
  8. _logger.debug("Number of rows updated:[{}]", count);
  9. } catch (SQLException ex) {
  10. _logger.error("unable to update rule triggered status", ex);
  11. }
  12. }

代码示例来源:origin: annmuor/jnode

  1. public void update(String field, Object value, Object... args) {
  2. try {
  3. UpdateBuilder<T, ?> ub = getDao().updateBuilder();
  4. buildWhere(ub, true, args);
  5. ub.updateColumnValue(field, value);
  6. ub.update();
  7. } catch (SQLException e) {
  8. logger.l1("SQL Exception in update", e);
  9. logger.l1(MessageFormat.format("we worked with {0} {1} {2}", field,
  10. value, Arrays.toString(args)));
  11. }
  12. }

代码示例来源:origin: mycontroller-org/mycontroller

  1. private void enableDisable(List<Integer> ids, boolean enabled) {
  2. try {
  3. UpdateBuilder<ForwardPayload, Integer> updateBuilder = this.getDao().updateBuilder();
  4. updateBuilder.updateColumnValue(ForwardPayload.KEY_ENABLED, enabled).where()
  5. .in(ForwardPayload.KEY_ID, ids);
  6. int updateCount = updateBuilder.update();
  7. _logger.debug("Updated rows count:{}", updateCount);
  8. } catch (SQLException ex) {
  9. _logger.error("Failed to update, Ids:{}", ids, ex);
  10. throw new McDatabaseException(ex);
  11. }
  12. }

代码示例来源:origin: mycontroller-org/mycontroller

  1. @Override
  2. public void disableAllTriggered() {
  3. try {
  4. UpdateBuilder<RuleDefinitionTable, Integer> updateBuilder = getDao().updateBuilder();
  5. updateBuilder.updateColumnValue(RuleDefinitionTable.KEY_TRIGGERED, false).where()
  6. .eq(RuleDefinitionTable.KEY_TRIGGERED, true);
  7. Integer count = updateBuilder.update();
  8. _logger.debug("Number of rows updated:[{}]", count);
  9. } catch (SQLException ex) {
  10. _logger.error("unable to update rule triggered status", ex);
  11. throw new McDatabaseException(ex);
  12. }
  13. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. @Override
  2. public void updateTimestamp(int sensorVariableId, long timestampOld, long timestanpNew) {
  3. try {
  4. UpdateBuilder<MetricsBinaryTypeDevice, Object> _ub = getDao().updateBuilder();
  5. _ub.where().eq(MetricsBinaryTypeDevice.KEY_SENSOR_VARIABLE_ID, sensorVariableId).and()
  6. .eq(MetricsBinaryTypeDevice.KEY_TIMESTAMP, timestampOld);
  7. _ub.updateColumnValue(MetricsBinaryTypeDevice.KEY_TIMESTAMP, timestanpNew);
  8. int updateCount = _ub.update();
  9. _logger.debug("Update count:{}", updateCount);
  10. } catch (SQLException ex) {
  11. _logger.error("SQL Exception", ex);
  12. }
  13. }
  14. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. @Override
  2. public void update(String key, String subKey, String value) {
  3. try {
  4. //Create it if not available
  5. createIfNotAvailable(key, subKey);
  6. UpdateBuilder<Settings, Integer> updateBuilder = this.getDao().updateBuilder();
  7. updateBuilder.where().eq(Settings.KEY_KEY, key).and().eq(Settings.KEY_SUB_KEY, subKey);
  8. updateBuilder.updateColumnValue(Settings.KEY_VALUE, value);
  9. int count = updateBuilder.update();
  10. _logger.debug("update count:{}", count);
  11. } catch (SQLException ex) {
  12. _logger.error("unable to get item for key:{}, subKey:{}", key, subKey, ex);
  13. }
  14. }

代码示例来源:origin: mycontroller-org/mycontroller

  1. @Override
  2. public void updateTimestamp(int sensorVariableId, long timestampOld, long timestanpNew) {
  3. try {
  4. UpdateBuilder<MetricsBinaryTypeDevice, Object> _ub = getDao().updateBuilder();
  5. _ub.where().eq(MetricsBinaryTypeDevice.KEY_SENSOR_VARIABLE_ID, sensorVariableId).and()
  6. .eq(MetricsBinaryTypeDevice.KEY_TIMESTAMP, timestampOld);
  7. _ub.updateColumnValue(MetricsBinaryTypeDevice.KEY_TIMESTAMP, timestanpNew);
  8. int updateCount = _ub.update();
  9. _logger.debug("Update count:{}", updateCount);
  10. } catch (SQLException ex) {
  11. _logger.error("SQL Exception", ex);
  12. throw new McDatabaseException(ex);
  13. }
  14. }
  15. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. private void updateEnabled(RESOURCE_TYPE resourceType, Integer resourceId, boolean enabled) {
  2. try {
  3. UpdateBuilder<Resource, Integer> updateBuilder = getDao().updateBuilder();
  4. Where<Resource, Integer> where = updateBuilder.where();
  5. int whereCount = 0;
  6. where.eq(Resource.KEY_RESOURCE_TYPE, resourceType);
  7. whereCount++;
  8. where.eq(Resource.KEY_RESOURCE_ID, resourceId);
  9. where.and(whereCount);
  10. updateBuilder.setWhere(where);
  11. updateBuilder.updateColumnValue(Resource.KEY_ENABLED, enabled);
  12. int updateCount = updateBuilder.update();
  13. _logger.debug("Update count:{}", updateCount);
  14. } catch (SQLException ex) {
  15. _logger.error("Failed to update! input:[resourceType:{}, resourceId:{}, enabled:{}], ",
  16. resourceType, resourceId, enabled, ex);
  17. }
  18. }

代码示例来源:origin: org.mycontroller.standalone/mycontroller-core

  1. @Override
  2. public void update(String key, String subKey, String value, String altValue) {
  3. try {
  4. //Create it if not available
  5. createIfNotAvailable(key, subKey);
  6. UpdateBuilder<Settings, Integer> updateBuilder = this.getDao().updateBuilder();
  7. updateBuilder.where().eq(Settings.KEY_KEY, key).and().eq(Settings.KEY_SUB_KEY, subKey);
  8. updateBuilder.updateColumnValue(Settings.KEY_VALUE, value);
  9. updateBuilder.updateColumnValue(Settings.KEY_ALT_VALUE, altValue);
  10. int count = updateBuilder.update();
  11. _logger.debug("update count:{}", count);
  12. } catch (SQLException ex) {
  13. _logger.error("unable to get item for key:{}, subKey:{}", key, subKey, ex);
  14. }
  15. }

代码示例来源:origin: mycontroller-org/mycontroller

  1. @Override
  2. public void update(String key, String subKey, String value) {
  3. try {
  4. //Create it if not available
  5. createIfNotAvailable(key, subKey);
  6. UpdateBuilder<Settings, Integer> updateBuilder = this.getDao().updateBuilder();
  7. updateBuilder.where().eq(Settings.KEY_KEY, key).and().eq(Settings.KEY_SUB_KEY, subKey);
  8. updateBuilder.updateColumnValue(Settings.KEY_VALUE, value);
  9. int count = updateBuilder.update();
  10. _logger.debug("update count:{}", count);
  11. } catch (SQLException ex) {
  12. _logger.error("unable to get item for key:{}, subKey:{}", key, subKey, ex);
  13. throw new McDatabaseException(ex);
  14. }
  15. }

代码示例来源:origin: mycontroller-org/mycontroller

  1. @Override
  2. public void update(String key, String subKey, String value, String altValue) {
  3. try {
  4. //Create it if not available
  5. createIfNotAvailable(key, subKey);
  6. UpdateBuilder<Settings, Integer> updateBuilder = this.getDao().updateBuilder();
  7. updateBuilder.where().eq(Settings.KEY_KEY, key).and().eq(Settings.KEY_SUB_KEY, subKey);
  8. updateBuilder.updateColumnValue(Settings.KEY_VALUE, value);
  9. updateBuilder.updateColumnValue(Settings.KEY_ALT_VALUE, altValue);
  10. int count = updateBuilder.update();
  11. _logger.debug("update count:{}", count);
  12. } catch (SQLException ex) {
  13. _logger.error("unable to get item for key:{}, subKey:{}", key, subKey, ex);
  14. throw new McDatabaseException(ex);
  15. }
  16. }

代码示例来源:origin: j256/ormlite-core

  1. @Test
  2. public void testUpdateTwoNullsInSeperateStatements() throws Exception {
  3. Dao<Foo, Integer> dao = createDao(Foo.class, true);
  4. UpdateBuilder<Foo, Integer> ub = dao.updateBuilder();
  5. ub.updateColumnValue(Foo.STRING_COLUMN_NAME, null);
  6. dao.update(ub.prepare());
  7. ub = dao.updateBuilder();
  8. ub.updateColumnValue(Foo.EQUAL_COLUMN_NAME, null);
  9. dao.update(ub.prepare());
  10. }

代码示例来源:origin: j256/ormlite-core

  1. @Test
  2. public void testUpdateTwoDates() throws Exception {
  3. Dao<TwoDates, Integer> dao = createDao(TwoDates.class, true);
  4. TwoDates foo = new TwoDates();
  5. long now = System.currentTimeMillis();
  6. Date date1 = new Date(now);
  7. Date date2 = new Date(now + 1000);
  8. foo.date1 = date1;
  9. foo.date2 = date2;
  10. assertEquals(1, dao.create(foo));
  11. UpdateBuilder<TwoDates, Integer> ub = dao.updateBuilder();
  12. ub.updateColumnValue(TwoDates.FIELD_NAME_DATE1, date2);
  13. ub.updateColumnValue(TwoDates.FIELD_NAME_DATE2, date1);
  14. dao.update(ub.prepare());
  15. }

代码示例来源:origin: j256/ormlite-core

  1. @Test
  2. public void testUpdateTwoNulls() throws Exception {
  3. Dao<Foo, Integer> dao = createDao(Foo.class, true);
  4. UpdateBuilder<Foo, Integer> ub = dao.updateBuilder();
  5. ub.updateColumnValue(Foo.STRING_COLUMN_NAME, null);
  6. ub.updateColumnValue(Foo.EQUAL_COLUMN_NAME, null);
  7. dao.update(ub.prepare());
  8. }

代码示例来源:origin: j256/ormlite-core

  1. @Test
  2. public void testUpdateBuildUpdateMathod() throws Exception {
  3. Dao<UpdateDate, Integer> dao = createDao(UpdateDate.class, true);
  4. UpdateDate updateDate = new UpdateDate();
  5. updateDate.date = new Date();
  6. assertEquals(1, dao.create(updateDate));
  7. Date newDate = new Date(System.currentTimeMillis() + 10);
  8. UpdateBuilder<UpdateDate, Integer> ub = dao.updateBuilder();
  9. ub.updateColumnValue(UpdateDate.DATE_FIELD, newDate);
  10. // this used to cause a NPE because of a missing args
  11. assertEquals(1, ub.update());
  12. // make sure the update worked
  13. UpdateDate result = dao.queryForId(updateDate.id);
  14. assertNotNull(result);
  15. assertEquals(newDate, result.date);
  16. }

代码示例来源:origin: com.j256.ormlite/ormlite-jdbc

  1. @Test
  2. public void testPrepareStatementUpdateValueNumber() throws Exception {
  3. Dao<Foo, Integer> fooDao = createDao(Foo.class, true);
  4. Foo foo = new Foo();
  5. foo.val = 123213;
  6. assertEquals(1, fooDao.create(foo));
  7. QueryBuilder<Foo, Integer> stmtb = fooDao.queryBuilder();
  8. stmtb.where().eq(Foo.ID_FIELD_NAME, foo.id);
  9. List<Foo> results = fooDao.query(stmtb.prepare());
  10. assertEquals(1, results.size());
  11. UpdateBuilder<Foo, Integer> updateb = fooDao.updateBuilder();
  12. updateb.updateColumnValue(Foo.VAL_FIELD_NAME, foo.val + 1);
  13. assertEquals(1, fooDao.update(updateb.prepare()));
  14. results = fooDao.query(stmtb.prepare());
  15. assertEquals(1, results.size());
  16. assertEquals(foo.val + 1, results.get(0).val);
  17. }

代码示例来源:origin: j256/ormlite-core

  1. @Test(expected = SQLException.class)
  2. public void testUpdatePreparedThrow() throws Exception {
  3. Dao<Foo, Integer> dao = createDao(Foo.class, true);
  4. Foo foo = new Foo();
  5. assertEquals(1, dao.create(foo));
  6. DatabaseConnection conn = connectionSource.getReadWriteConnection(FOO_TABLE_NAME);
  7. try {
  8. conn.close();
  9. UpdateBuilder<Foo, Integer> ub = dao.updateBuilder();
  10. ub.updateColumnValue(Foo.EQUAL_COLUMN_NAME, 1);
  11. dao.update(ub.prepare());
  12. } finally {
  13. connectionSource.releaseConnection(conn);
  14. }
  15. }

相关文章