org.jdbi.v3.core.Handle.useTransaction()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(8.4k)|赞(0)|评价(0)|浏览(212)

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

Handle.useTransaction介绍

[英]Executes callback in a transaction.
[中]在事务中执行callback。

代码示例

代码示例来源：origin: jdbi/jdbi

/**
 * A convenience function which manages the lifecycle of a handle and yields it to a callback
 * for use by clients. The handle will be in a transaction when the callback is invoked, and
 * that transaction will be committed if the callback finishes normally, or rolled back if the
 * callback raises an exception.
 *
 * @param callback A callback which will receive an open Handle, in a transaction
 * @param <X> exception type thrown by the callback, if any.
 *
 * @throws X any exception thrown by the callback
 */
public <X extends Exception> void useTransaction(final HandleConsumer<X> callback) throws X {
  useHandle(handle -> handle.useTransaction(callback));
}

代码示例来源：origin: jdbi/jdbi

/**
 * A convenience function which manages the lifecycle of a handle and yields it to a callback
 * for use by clients. The handle will be in a transaction when the callback is invoked, and
 * that transaction will be committed if the callback finishes normally, or rolled back if the
 * callback raises an exception.
 *
 * <p>
 * This form accepts a transaction isolation level which will be applied to the connection
 * for the scope of this transaction, after which the original isolation level will be restored.
 * </p>
 *
 * @param level the transaction isolation level which will be applied to the connection for the scope of this
 *              transaction, after which the original isolation level will be restored.
 * @param callback A callback which will receive an open Handle, in a transaction
 * @param <X> exception type thrown by the callback, if any.
 *
 * @throws X any exception thrown by the callback
 */
public <X extends Exception> void useTransaction(final TransactionIsolationLevel level, final HandleConsumer<X> callback) throws X {
  useHandle(handle -> handle.useTransaction(level, callback));
}

代码示例来源：origin: jdbi/jdbi

@Test
public void testRollbackDoesntCommit() {
  assertThat(begin).isEqualTo(0);
  h.useTransaction(th -> {
    assertThat(begin).isEqualTo(1);
    assertThat(rollback).isEqualTo(0);
    th.rollback();
  });
  assertThat(rollback).isEqualTo(1);
  assertThat(commit).isEqualTo(0);
}

代码示例来源：origin: jdbi/jdbi

@Test
public void testRollbackFailDoesntLeak() throws Exception {
  final BoomHandler handler = new BoomHandler();
  dbRule.getJdbi().setTransactionHandler(handler);
  final Handle h = dbRule.openHandle();
  assertThat(h.isClosed()).isFalse();
  handler.failRollback = true;
  assertThatThrownBy(() -> h.useTransaction(h2 -> h2.execute("insert into true")))
    .isInstanceOf(UnableToCreateStatementException.class);
  assertThat(h.isInTransaction())
    .describedAs("rollback failed but handle should still be in transaction").isTrue();
  assertThatThrownBy(h::close)
    .isInstanceOf(CloseException.class);
  assertThat(h.isClosed()).isTrue();
  assertThat(h.getConnection().isClosed()).isTrue();
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  handle.useTransaction(h -> {
    h.execute("DROP TABLE IF EXISTS users");
    h.execute("CREATE TABLE users (id SERIAL PRIMARY KEY, name VARCHAR)");
    for (String name : Arrays.asList("Alice", "Bob", "Charlie", "Data")) {
      h.execute("INSERT INTO users(name) VALUES (?)", name);
    }
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setupDbi() {
  h = db.getHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS foo");
    th.execute("CREATE TABLE foo (bar UUID, ary UUID[])");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  h = db.getHandle();
  h.useTransaction(th -> {
    th.execute("drop table if exists stuff");
    th.execute("create table stuff (ts timestamp, d date, z text)");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  h = dbRule.getSharedHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS uuids");
    th.execute("CREATE TABLE uuids (u ARRAY)");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  h = db.getHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS uuids");
    th.execute("CREATE TABLE uuids (u UUID[], i INT[])");
  });
  ao = h.attach(ArrayObject.class);
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  handle = postgresDbRule.getHandle();
  handle.useTransaction(h -> {
    h.execute("drop table if exists campaigns");
    h.execute("create table campaigns(id int not null, caps hstore)");
    h.execute("insert into campaigns(id, caps) values (1, 'yearly=>10000, monthly=>5000, daily=>200'::hstore)");
    h.execute("insert into campaigns(id, caps) values (2, 'yearly=>1000, monthly=>200, daily=>20'::hstore)");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  handle = postgresDbRule.getHandle();
  handle.useTransaction(h -> {
    h.execute("drop table if exists campaigns");
    h.execute("create table campaigns(id int not null, caps hstore)");
    h.execute("insert into campaigns(id, caps) values (1, 'yearly=>10000, monthly=>5000, daily=>200'::hstore)");
    h.execute("insert into campaigns(id, caps) values (2, 'yearly=>1000, monthly=>200, daily=>20'::hstore)");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setupDbi() {
  h = db.getHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS values");
    th.execute("DROP TYPE IF EXISTS enum_t");
    th.execute("CREATE TYPE enum_t AS ENUM ('FOO', 'BAR', 'BAZ')");
    th.execute("CREATE TABLE values (value enum_t)");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  Jdbi jdbi = Jdbi.create("jdbc:sqlite::memory:");
  jdbi.installPlugin(new SQLitePlugin());
  handle = jdbi.open();
  handle.useTransaction(handle -> handle.execute("CREATE TABLE foo(url URL);"));
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  dao = dbRule.getSharedHandle().attach(Dao.class);
  dbRule.getSharedHandle().useTransaction(h -> {
    h.execute("insert into something (id, name) values (1, 'Alice')");
    h.execute("insert into something (id, name) values (2, 'Bob')");
    h.execute("insert into something (id, name) values (3, 'Charles')");
  });
}

代码示例来源：origin: jdbi/jdbi

@Test
public void testTxnReentrant() {
  final TheBasics dao = db.onDemand(TheBasics.class);
  dao.withHandle(handle1 -> {
    handle1.useTransaction(h -> {
      dao.insert(new Something(1, "x"));
      List<String> rs = h.createQuery("select name from something where id = 1")
          .mapTo(String.class)
          .list();
      assertThat(rs).hasSize(1);
      h.createQuery("SELECT 1").mapTo(int.class).list();
    });
    return null;
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  dbRule.getJdbi()
      .registerArrayType(Integer.class, "integer")
      .registerArrayType(UUID.class, "uuid");
  h = dbRule.openHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS arrays");
    th.execute("CREATE TABLE arrays (u UUID[], i INT[])");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  handle = postgresDbRule.getHandle();
  handle.useTransaction(h -> {
    h.execute("drop table if exists intervals");
    h.execute("create table intervals(id int not null, foo interval)");
    // Can be periods.
    h.execute("insert into intervals(id, foo) values(1, interval '2 years -3 months 40 days')");
    h.execute("insert into intervals(id, foo) values(2, interval '7 days')");
    // Can't be.
    h.execute("insert into intervals(id, foo) values(3, interval '10 years -3 months 100 seconds')");
  });
}

代码示例来源：origin: jdbi/jdbi

@Before
public void setUp() {
  handle = postgresDbRule.getHandle();
  handle.useTransaction(h -> {
    h.execute("drop table if exists intervals");
    h.execute("create table intervals(id int not null, foo interval)");
    // Can be durations.
    h.execute("insert into intervals(id, foo) values(1, interval '1 day 15:00:00')");
    h.execute("insert into intervals(id, foo) values(2, interval '40 days 22 minutes')");
    // Can't be.
    h.execute("insert into intervals(id, foo) values(3, interval '10 years -3 months 100 seconds')");
  });
}

代码示例来源：origin: org.jdbi/jdbi3-sqlobject

@Before
public void setUp() {
  dao = dbRule.getSharedHandle().attach(Dao.class);
  dbRule.getSharedHandle().useTransaction(h -> {
    h.execute("insert into something (id, name) values (1, 'Alice')");
    h.execute("insert into something (id, name) values (2, 'Bob')");
    h.execute("insert into something (id, name) values (3, 'Charles')");
  });
}

代码示例来源：origin: org.jdbi/jdbi3-guava

@Before
public void setUp() {
  dbRule.getJdbi()
      .registerArrayType(Integer.class, "integer")
      .registerArrayType(UUID.class, "uuid");
  h = dbRule.openHandle();
  h.useTransaction(th -> {
    th.execute("DROP TABLE IF EXISTS arrays");
    th.execute("CREATE TABLE arrays (u UUID[], i INT[])");
  });
}

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

Handle

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com