本文整理了Java中org.jdbi.v3.core.Jdbi.installPlugin()
方法的一些代码示例,展示了Jdbi.installPlugin()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jdbi.installPlugin()
方法的具体详情如下:
包路径:org.jdbi.v3.core.Jdbi
类名称:Jdbi
方法名:installPlugin
[英]Install a given JdbiPlugin instance that will configure any provided Handle instances.
[中]安装一个给定的JdbiPlugin实例,该实例将配置任何提供的句柄实例。
代码示例来源:origin: dropwizard/dropwizard
/**
* Overridable function to allow extra customization of the created {@link Jdbi}
* instance.
*
* <p>
* If this is overridden it is strongly recommend that
* {@code super.configure(jdbi, configuration)} is invoked before any other
* changes are made if you intend to use the default as a base so that the
* customized settings will supersede the defaults
* </p>
*
* @param jdbi
*/
protected void configure(final Jdbi jdbi) {
jdbi.installPlugin(new SqlObjectPlugin());
jdbi.installPlugin(new JodaTimePlugin());
jdbi.installPlugin(new GuavaPlugin());
}
}
代码示例来源:origin: prestodb/presto
@Inject
public MysqlDaoProvider(DbResourceGroupConfig config)
{
requireNonNull(config, "DbResourceGroupConfig is null");
MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setURL(requireNonNull(config.getConfigDbUrl(), "resource-groups.config-db-url is null"));
this.dao = Jdbi.create(dataSource)
.installPlugin(new SqlObjectPlugin())
.onDemand(ResourceGroupsDao.class);
}
代码示例来源:origin: jdbi/jdbi
@Override
public void customizeJdbi(Jdbi jdbi) {
jdbi.installPlugin(new JsonPlugin());
jdbi.getConfig(JsonConfig.class).setJsonMapper(new GsonJsonMapper());
}
}
代码示例来源:origin: jdbi/jdbi
@Override
public void customizeJdbi(Jdbi jdbi) {
jdbi.installPlugin(new JsonPlugin());
jdbi.getConfig(JsonConfig.class).setJsonMapper(new JacksonJsonMapper());
}
}
代码示例来源:origin: prestodb/presto
@Inject
public H2DaoProvider(DbResourceGroupConfig config)
{
JdbcDataSource ds = new JdbcDataSource();
ds.setURL(requireNonNull(config.getConfigDbUrl(), "resource-groups.config-db-url is null"));
// TODO: this should use onDemand()
this.dao = Jdbi.create(ds)
.installPlugin(new SqlObjectPlugin())
.open()
.attach(H2ResourceGroupsDao.class);
}
代码示例来源:origin: jdbi/jdbi
@Before
public void setUp() {
ds = new JdbcDataSource();
// in MVCC mode h2 doesn't shut down immediately on all connections closed, so need random db name
ds.setURL(String.format("jdbc:h2:mem:%s;MVCC=TRUE", UUID.randomUUID()));
db = Jdbi.create(ds);
db.installPlugin(new SqlObjectPlugin());
handle = db.open();
handle.execute("create table something (id int primary key, name varchar(100))");
db.installPlugin(tracker);
}
代码示例来源:origin: jdbi/jdbi
@Test
public void testCorrectExceptionIfUnableToConnectOnAttach() {
assertThatThrownBy(() -> Jdbi.create("jdbc:mysql://invalid.invalid/test", "john", "scott")
.installPlugin(new SqlObjectPlugin())
.open()
.attach(Spiffy.class)).isInstanceOf(ConnectionException.class);
}
代码示例来源:origin: jdbi/jdbi
@Test
public void testCorrectExceptionIfUnableToConnectOnDemand() {
assertThatThrownBy(() -> Jdbi.create("jdbc:mysql://invalid.invalid/test", "john", "scott")
.installPlugin(new SqlObjectPlugin())
.onDemand(Spiffy.class)
.findNameById(1)).isInstanceOf(ConnectionException.class);
}
代码示例来源:origin: jdbi/jdbi
@Test
public void testCustomizeHandle() {
Handle h = mock(Handle.class);
dbRule.getJdbi().installPlugin(new JdbiPlugin() {
@Override
public Handle customizeHandle(Handle handle) {
return h;
}
});
assertThat(h).isSameAs(dbRule.getJdbi().open());
}
代码示例来源:origin: jdbi/jdbi
@Before
public void before() {
jdbi = db.getJdbi().installPlugin(new Gson2Plugin());
}
}
代码示例来源:origin: jdbi/jdbi
@Test
public void testCustomizeConnection() {
Connection c = mock(Connection.class);
dbRule.getJdbi().installPlugin(new JdbiPlugin() {
@Override
public Connection customizeConnection(Connection conn) {
return c;
}
});
assertThat(c).isSameAs(dbRule.getJdbi().open().getConnection());
}
}
代码示例来源:origin: jdbi/jdbi
@Before
public void before() {
jdbi = db.getJdbi().installPlugin(new Jackson2Plugin());
jdbi.getConfig(Jackson2Config.class).setMapper(new ObjectMapper().registerModule(new ParameterNamesModule()));
}
}
代码示例来源:origin: jdbi/jdbi
@Before
public void setUp() {
final JdbcDataSource ds = new JdbcDataSource() {
private static final long serialVersionUID = 1L;
@Override
public Connection getConnection() {
throw new UnsupportedOperationException();
}
};
db = Jdbi.create(ds);
db.installPlugin(new SqlObjectPlugin());
dao = db.onDemand(UselessDao.class);
}
代码示例来源:origin: jdbi/jdbi
@Before
public void setUp() {
db = Jdbi.create("jdbc:h2:mem:" + UUID.randomUUID());
db.installPlugin(new SqlObjectPlugin());
handle = db.open();
handle.createUpdate(
"create table foo (id int, bar varchar(100) default null);")
.execute();
dao = db.onDemand(MyDAO.class);
}
代码示例来源:origin: jdbi/jdbi
@Before
public void setUp() {
JdbcDataSource ds = new JdbcDataSource();
// in MVCC mode h2 doesn't shut down immediately on all connections closed, so need random db name
ds.setURL(String.format("jdbc:h2:mem:%s;MVCC=TRUE", UUID.randomUUID()));
db = Jdbi.create(ds);
db.installPlugin(new SqlObjectPlugin());
db.registerRowMapper(new SomethingMapper());
handle = db.open();
handle.execute("create table something (id int primary key, name varchar(100))");
}
代码示例来源: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() {
JdbcDataSource ds = new JdbcDataSource();
ds.setURL("jdbc:h2:mem:" + UUID.randomUUID());
db = Jdbi.create(ds);
db.installPlugin(new SqlObjectPlugin());
db.registerRowMapper(new SomethingMapper());
handle = db.open();
handle.execute("create table something (id int primary key, name varchar(100))");
}
代码示例来源:origin: jdbi/jdbi
@Before
public void before() {
final Jdbi db = dbRule.getJdbi();
db.installPlugin(new SqlObjectPlugin());
db.registerRowMapper(new SomethingMapper());
handle = db.open();
handle.execute("insert into something(id, name) values(1, '1')");
handle.execute("insert into something(id, name) values(2, '2')");
// "control group" element that should *not* be returned by the queries
handle.execute("insert into something(id, name) values(3, '3')");
expectedSomethings = Arrays.asList(new Something(1, "1"), new Something(2, "2"));
}
代码示例来源:origin: jdbi/jdbi
@Before
public void before() {
final Jdbi db = dbRule.getJdbi();
db.installPlugin(new SqlObjectPlugin());
db.registerRowMapper(new SomethingMapper());
handle = db.open();
handle.execute("insert into something(id, name) values(1, '1')");
handle.execute("insert into something(id, name) values(2, '2')");
// "control group" element that should *not* be returned by the queries
handle.execute("insert into something(id, name) values(3, '3')");
expectedSomethings = Arrays.asList(new Something(1, "1"), new Something(2, "2"));
}
代码示例来源:origin: jdbi/jdbi
@Before
public void before() {
final Jdbi db = dbRule.getJdbi();
db.installPlugin(new SqlObjectPlugin());
db.registerRowMapper(new SomethingMapper());
handle = db.open();
handle.execute("insert into something(id, name) values(1, '1')");
handle.execute("insert into something(id, name) values(2, '2')");
// "control group" element that should *not* be returned by the queries
handle.execute("insert into something(id, name) values(3, '3')");
expectedSomethings = Arrays.asList(new Something(1, "1"), new Something(2, "2"));
}
内容来源于网络,如有侵权,请联系作者删除!