Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove dropwizard-jdbc dependency from lookups-cached-single. (#3573) 

Fixes #3548.
This commit is contained in:
Gian Merlino 2016-10-17 09:37:47 -05:00 committed by Fangjin Yang
parent 0ce33bc95f
commit c1d3b8a30c
2 changed files with 34 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
extensions-core/lookups-cached-single/pom.xml
View File

@ -56,11 +56,6 @@
<groupId>org.mapdb</groupId>
<artifactId>mapdb</artifactId>
</dependency>
<dependency>
<groupId>io.dropwizard</groupId>
<artifactId>dropwizard-jdbi</artifactId>
<version>0.9.2</version>
</dependency>
<dependency>
<groupId>org.antlr</groupId>
<artifactId>stringtemplate</artifactId>

38
extensions-core/lookups-cached-single/src/main/java/io/druid/server/lookup/jdbc/QueryKeys.java
View File

@ -21,19 +21,19 @@ package io.druid.server.lookup.jdbc;
import com.google.common.collect.ImmutableSet;
import io.dropwizard.jdbi.ImmutableSetContainerFactory;
import org.skife.jdbi.v2.ContainerBuilder;
import org.skife.jdbi.v2.sqlobject.SqlQuery;
import org.skife.jdbi.v2.sqlobject.customizers.Define;
import org.skife.jdbi.v2.sqlobject.customizers.RegisterContainerMapper;
import org.skife.jdbi.v2.sqlobject.stringtemplate.UseStringTemplate3StatementLocator;
import org.skife.jdbi.v2.tweak.ContainerFactory;
import org.skife.jdbi.v2.unstable.BindIn;
import java.util.List;
import java.util.Map;
@UseStringTemplate3StatementLocator()
@RegisterContainerMapper(ImmutableSetContainerFactory.class)
@RegisterContainerMapper(QueryKeys.QueryKeysContainerFactory.class)
public interface QueryKeys
{
@SqlQuery("SELECT <keyColumn>, <valueColumn> FROM <table> WHERE <keyColumn> IN (<keys>)")
@ -43,5 +43,35 @@ public interface QueryKeys
@Define("keyColumn") String keyColumn,
@Define("valueColumn") String valueColumn
);
}
static class QueryKeysContainerFactory implements ContainerFactory<ImmutableSet<?>>
{
@Override
public boolean accepts(Class<?> type)
{
return ImmutableSet.class.isAssignableFrom(type);
}
@Override
public ContainerBuilder<ImmutableSet<?>> newContainerBuilderFor(Class<?> type)
{
return new ContainerBuilder<ImmutableSet<?>>()
{
final ImmutableSet.Builder<Object> builder = new ImmutableSet.Builder<>();
@Override
public ContainerBuilder<ImmutableSet<?>> add(final Object obj)
{
builder.add(obj);
return this;
}
@Override
public ImmutableSet<?> build()
{
return builder.build();
}
};
}
}
}