本文整理汇总了Java中org.apache.calcite.avatica.AvaticaFactory类的典型用法代码示例。如果您正苦于以下问题:Java AvaticaFactory类的具体用法?Java AvaticaFactory怎么用?Java AvaticaFactory使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
AvaticaFactory类属于org.apache.calcite.avatica包,在下文中一共展示了AvaticaFactory类的15个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: CalciteConnectionImpl
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
/**
* Creates a CalciteConnectionImpl.
* <p/>
* <p>Not public; method is called only from the driver.</p>
*
* @param driver Driver
* @param factory Factory for JDBC objects
* @param url Server URL
* @param info Other connection properties
* @param rootSchema Root schema, or null
* @param typeFactory Type factory, or null
*/
protected CalciteConnectionImpl(Driver driver, AvaticaFactory factory,
String url, Properties info, CalciteSchema rootSchema,
JavaTypeFactory typeFactory) {
super(driver, factory, url, info);
CalciteConnectionConfig cfg = new CalciteConnectionConfigImpl(info);
this.prepareFactory = driver.getPrepareFactory();
if (typeFactory != null) {
this.typeFactory = typeFactory;
} else {
final RelDataTypeSystem typeSystem =
cfg.typeSystem(RelDataTypeSystem.class, RelDataTypeSystem.DEFAULT);
this.typeFactory = new JavaTypeFactoryImpl(typeSystem);
}
this.rootSchema =
Preconditions.checkNotNull(rootSchema != null
? rootSchema
: CalciteSchema.createRootSchema(true));
Preconditions.checkArgument(this.rootSchema.isRoot(), "must be root schema");
this.properties.put(InternalProperty.CASE_SENSITIVE, cfg.caseSensitive());
this.properties.put(InternalProperty.UNQUOTED_CASING, cfg.unquotedCasing());
this.properties.put(InternalProperty.QUOTED_CASING, cfg.quotedCasing());
this.properties.put(InternalProperty.QUOTING, cfg.quoting());
}
开发者ID:bitnine-oss,项目名称:octopus,代码行数:36,代码来源:CalciteConnectionImpl.java
示例2: QuarkConnectionImpl
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
protected QuarkConnectionImpl(QuarkDriver driver, AvaticaFactory factory, String url,
Properties info, CalciteRootSchema rootSchema,
JavaTypeFactory typeFactory) throws SQLException {
super(driver, factory, url, info);
CalciteConnectionConfig cfg = new CalciteConnectionConfigImpl(info);
if (typeFactory != null) {
this.typeFactory = typeFactory;
} else {
final RelDataTypeSystem typeSystem =
cfg.typeSystem(RelDataTypeSystem.class, RelDataTypeSystem.DEFAULT);
this.typeFactory = new JavaTypeFactoryImpl(typeSystem);
}
this.properties.put(InternalProperty.CASE_SENSITIVE, cfg.caseSensitive());
this.properties.put(InternalProperty.UNQUOTED_CASING, cfg.unquotedCasing());
this.properties.put(InternalProperty.QUOTED_CASING, cfg.quotedCasing());
this.properties.put(InternalProperty.QUOTING, cfg.quoting());
}
开发者ID:qubole,项目名称:quark,代码行数:21,代码来源:QuarkConnectionImpl.java
示例3: CalciteConnectionImpl
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
/**
* Creates a CalciteConnectionImpl.
*
* <p>Not public; method is called only from the driver.</p>
*
* @param driver Driver
* @param factory Factory for JDBC objects
* @param url Server URL
* @param info Other connection properties
* @param rootSchema Root schema, or null
* @param typeFactory Type factory, or null
*/
protected CalciteConnectionImpl(Driver driver, AvaticaFactory factory,
String url, Properties info, CalciteSchema rootSchema,
JavaTypeFactory typeFactory) {
super(driver, factory, url, info);
CalciteConnectionConfig cfg = new CalciteConnectionConfigImpl(info);
this.prepareFactory = driver.prepareFactory;
if (typeFactory != null) {
this.typeFactory = typeFactory;
} else {
final RelDataTypeSystem typeSystem =
cfg.typeSystem(RelDataTypeSystem.class, RelDataTypeSystem.DEFAULT);
this.typeFactory = new JavaTypeFactoryImpl(typeSystem);
}
this.rootSchema =
Preconditions.checkNotNull(rootSchema != null
? rootSchema
: CalciteSchema.createRootSchema(true));
Preconditions.checkArgument(this.rootSchema.isRoot(), "must be root schema");
this.properties.put(InternalProperty.CASE_SENSITIVE, cfg.caseSensitive());
this.properties.put(InternalProperty.UNQUOTED_CASING, cfg.unquotedCasing());
this.properties.put(InternalProperty.QUOTED_CASING, cfg.quotedCasing());
this.properties.put(InternalProperty.QUOTING, cfg.quoting());
}
开发者ID:apache,项目名称:calcite,代码行数:36,代码来源:CalciteConnectionImpl.java
示例4: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
/**
* Creates a Dremio connection for Avatica (in terms of Avatica types).
* <p>
* This implementation delegates to
* {@link #newDremioConnection(DriverImpl, DremioFactory, String, Properties)}.
* </p>
*/
@Override
public final AvaticaConnection newConnection(UnregisteredDriver driver,
AvaticaFactory factory,
String url,
Properties info) throws SQLException {
return newConnection((DriverImpl) driver, (DremioFactory) factory, url, info);
}
开发者ID:dremio,项目名称:dremio-oss,代码行数:15,代码来源:DremioFactory.java
示例5: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
/**
* Creates a Drill connection for Avatica (in terms of Avatica types).
* <p>
* This implementation delegates to
* {@link #newDrillConnection(DriverImpl, DrillFactory, String, Properties)}.
* </p>
*/
@Override
public final AvaticaConnection newConnection(UnregisteredDriver driver,
AvaticaFactory factory,
String url,
Properties info) throws SQLException {
return newDrillConnection((DriverImpl) driver, (DrillFactory) factory, url, info);
}
开发者ID:axbaretto,项目名称:drill,代码行数:15,代码来源:DrillFactory.java
示例6: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
public final AvaticaConnection newConnection(
UnregisteredDriver driver,
AvaticaFactory factory,
String url,
Properties info) {
return newConnection(driver, factory, url, info, null, null);
}
开发者ID:bitnine-oss,项目名称:octopus,代码行数:8,代码来源:CalciteFactory.java
示例7: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
/**
* Creates a Quark connection for Avatica (in terms of Avatica types).
* <p>
* This implementation delegates to
* {@link #newConnection(QuarkDriver, QuarkJdbcFactory, String, Properties, CalciteRootSchema,
* JavaTypeFactory)}.
* </p>
*/
@Override
public final AvaticaConnection newConnection(UnregisteredDriver driver,
AvaticaFactory factory,
String url,
Properties info) throws SQLException {
return newConnection((QuarkDriver) driver, (QuarkJdbcFactory) factory, url, info,
null, null);
}
开发者ID:qubole,项目名称:quark,代码行数:17,代码来源:QuarkJdbcFactory.java
示例8: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
public final AvaticaConnection newConnection(
UnregisteredDriver driver,
AvaticaFactory factory,
String url,
Properties info) {
return newConnection(driver, factory, url, info, null, null);
}
开发者ID:apache,项目名称:calcite,代码行数:8,代码来源:CalciteFactory.java
示例9: getFactory
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
AvaticaFactory getFactory() {
return factory;
}
开发者ID:dremio,项目名称:dremio-oss,代码行数:4,代码来源:DremioConnectionImpl.java
示例10: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
public CalciteJdbc41Connection newConnection(UnregisteredDriver driver,
AvaticaFactory factory, String url, Properties info,
CalciteSchema rootSchema, JavaTypeFactory typeFactory) {
return new CalciteJdbc41Connection(
(kr.co.bitnine.octopus.engine.calcite.Driver) driver, factory, url, info, rootSchema, typeFactory);
}
开发者ID:bitnine-oss,项目名称:octopus,代码行数:7,代码来源:CalciteJdbc41Factory.java
示例11: CalciteJdbc41Connection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
CalciteJdbc41Connection(Driver driver, AvaticaFactory factory, String url,
Properties info, CalciteSchema rootSchema,
JavaTypeFactory typeFactory) {
super(driver, factory, url, info, rootSchema, typeFactory);
}
开发者ID:bitnine-oss,项目名称:octopus,代码行数:6,代码来源:CalciteJdbc41Factory.java
示例12: getFactory
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
AvaticaFactory getFactory() {
return factory;
}
开发者ID:bitnine-oss,项目名称:octopus,代码行数:4,代码来源:CalciteConnectionImpl.java
示例13: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
@Override
public AvaticaConnection newConnection(UnregisteredDriver driver, AvaticaFactory factory, String url, Properties info) throws SQLException {
return new KylinConnection(driver, (KylinJdbcFactory) factory, url, info);
}
开发者ID:apache,项目名称:kylin,代码行数:5,代码来源:KylinJdbcFactory.java
示例14: newConnection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
public CalciteJdbc41Connection newConnection(UnregisteredDriver driver,
AvaticaFactory factory, String url, Properties info,
CalciteSchema rootSchema, JavaTypeFactory typeFactory) {
return new CalciteJdbc41Connection(
(Driver) driver, factory, url, info, rootSchema, typeFactory);
}
开发者ID:apache,项目名称:calcite,代码行数:7,代码来源:CalciteJdbc41Factory.java
示例15: CalciteJdbc41Connection
import org.apache.calcite.avatica.AvaticaFactory; //导入依赖的package包/类
CalciteJdbc41Connection(Driver driver, AvaticaFactory factory, String url,
Properties info, CalciteSchema rootSchema,
JavaTypeFactory typeFactory) {
super(driver, factory, url, info, rootSchema, typeFactory);
}
开发者ID:apache,项目名称:calcite,代码行数:6,代码来源:CalciteJdbc41Factory.java
注:本文中的org.apache.calcite.avatica.AvaticaFactory类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论