public class JdbcMeta extends Object implements org.apache.calcite.avatica.remote.ProtobufMeta
Meta
upon an existing JDBC data source.Modifier and Type | Class and Description |
---|---|
static class |
JdbcMeta.ConnectionCacheSettings
Configurable connection cache settings.
|
static class |
JdbcMeta.StatementCacheSettings
Configurable statement cache settings.
|
org.apache.calcite.avatica.Meta.ConnectionHandle, org.apache.calcite.avatica.Meta.ConnectionProperties, org.apache.calcite.avatica.Meta.CursorFactory, org.apache.calcite.avatica.Meta.DatabaseProperty, org.apache.calcite.avatica.Meta.ExecuteBatchResult, org.apache.calcite.avatica.Meta.ExecuteResult, org.apache.calcite.avatica.Meta.Factory, org.apache.calcite.avatica.Meta.Frame, org.apache.calcite.avatica.Meta.MetaResultSet, org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.PrepareCallback, org.apache.calcite.avatica.Meta.Signature, org.apache.calcite.avatica.Meta.StatementHandle, org.apache.calcite.avatica.Meta.StatementType, org.apache.calcite.avatica.Meta.Style
Modifier and Type | Field and Description |
---|---|
static int |
UNLIMITED_COUNT
Special value for
Statement#getLargeMaxRows() that means fetch
an unlimited number of rows in a single batch. |
Constructor and Description |
---|
JdbcMeta(String url)
Creates a JdbcMeta.
|
JdbcMeta(String url,
Properties info) |
JdbcMeta(String url,
Properties info,
org.apache.calcite.avatica.metrics.MetricsSystem metrics)
Creates a JdbcMeta.
|
JdbcMeta(String url,
String user,
String password)
Creates a JdbcMeta.
|
Modifier and Type | Method and Description |
---|---|
protected void |
apply(Connection conn,
org.apache.calcite.avatica.Meta.ConnectionProperties connProps) |
void |
closeConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
void |
closeStatement(org.apache.calcite.avatica.Meta.StatementHandle h) |
protected static List<org.apache.calcite.avatica.ColumnMetaData> |
columns(ResultSetMetaData metaData)
Converts from JDBC metadata to Avatica columns.
|
void |
commit(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.ConnectionProperties |
connectionSync(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
org.apache.calcite.avatica.Meta.ConnectionProperties connProps) |
protected Connection |
createConnection(String url,
Properties info) |
Iterable<Object> |
createIterable(org.apache.calcite.avatica.Meta.StatementHandle handle,
org.apache.calcite.avatica.QueryState state,
org.apache.calcite.avatica.Meta.Signature signature,
List<org.apache.calcite.avatica.remote.TypedValue> parameterValues,
org.apache.calcite.avatica.Meta.Frame firstFrame) |
org.apache.calcite.avatica.Meta.StatementHandle |
createStatement(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.ExecuteResult |
execute(org.apache.calcite.avatica.Meta.StatementHandle h,
List<org.apache.calcite.avatica.remote.TypedValue> parameterValues,
int maxRowsInFirstFrame) |
org.apache.calcite.avatica.Meta.ExecuteResult |
execute(org.apache.calcite.avatica.Meta.StatementHandle h,
List<org.apache.calcite.avatica.remote.TypedValue> parameterValues,
long maxRowCount) |
org.apache.calcite.avatica.Meta.ExecuteBatchResult |
executeBatch(org.apache.calcite.avatica.Meta.StatementHandle h,
List<List<org.apache.calcite.avatica.remote.TypedValue>> updateBatches) |
org.apache.calcite.avatica.Meta.ExecuteBatchResult |
executeBatchProtobuf(org.apache.calcite.avatica.Meta.StatementHandle h,
List<org.apache.calcite.avatica.proto.Requests.UpdateBatch> updateBatches) |
org.apache.calcite.avatica.Meta.Frame |
fetch(org.apache.calcite.avatica.Meta.StatementHandle h,
long offset,
int fetchMaxRowCount) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getAttributes(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat typeNamePattern,
org.apache.calcite.avatica.Meta.Pat attributeNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getBestRowIdentifier(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table,
int scope,
boolean nullable) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getClientInfoProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getColumnPrivileges(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table,
org.apache.calcite.avatica.Meta.Pat columnNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat tableNamePattern,
org.apache.calcite.avatica.Meta.Pat columnNamePattern) |
protected Connection |
getConnection(String id) |
protected com.google.common.cache.Cache<String,Connection> |
getConnectionCache() |
org.apache.calcite.avatica.Meta.MetaResultSet |
getCrossReference(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String parentCatalog,
String parentSchema,
String parentTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
Map<org.apache.calcite.avatica.Meta.DatabaseProperty,Object> |
getDatabaseProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getExportedKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getFunctionColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat functionNamePattern,
org.apache.calcite.avatica.Meta.Pat columnNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getFunctions(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat functionNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getImportedKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getIndexInfo(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table,
boolean unique,
boolean approximate) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getPrimaryKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getProcedureColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat procedureNamePattern,
org.apache.calcite.avatica.Meta.Pat columnNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getProcedures(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat procedureNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getPseudoColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat tableNamePattern,
org.apache.calcite.avatica.Meta.Pat columnNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern) |
protected com.google.common.cache.Cache<Integer,StatementInfo> |
getStatementCache() |
protected AtomicInteger |
getStatementIdGenerator() |
org.apache.calcite.avatica.Meta.MetaResultSet |
getSuperTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat tableNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getSuperTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat typeNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getTablePrivileges(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat tableNamePattern) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat tableNamePattern,
List<String> typeList) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getTableTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getTypeInfo(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getUDTs(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
org.apache.calcite.avatica.Meta.Pat schemaPattern,
org.apache.calcite.avatica.Meta.Pat typeNamePattern,
int[] types) |
org.apache.calcite.avatica.Meta.MetaResultSet |
getVersionColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String catalog,
String schema,
String table) |
void |
openConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
Map<String,String> info) |
protected static List<org.apache.calcite.avatica.AvaticaParameter> |
parameters(ParameterMetaData metaData)
Converts from JDBC metadata to Avatica parameters
|
org.apache.calcite.avatica.Meta.StatementHandle |
prepare(org.apache.calcite.avatica.Meta.ConnectionHandle ch,
String sql,
long maxRowCount) |
org.apache.calcite.avatica.Meta.ExecuteResult |
prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h,
String sql,
long maxRowCount,
int maxRowsInFirstFrame,
org.apache.calcite.avatica.Meta.PrepareCallback callback) |
org.apache.calcite.avatica.Meta.ExecuteResult |
prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h,
String sql,
long maxRowCount,
org.apache.calcite.avatica.Meta.PrepareCallback callback) |
org.apache.calcite.avatica.Meta.ExecuteBatchResult |
prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle h,
List<String> sqlCommands) |
void |
rollback(org.apache.calcite.avatica.Meta.ConnectionHandle ch) |
protected static org.apache.calcite.avatica.Meta.Signature |
signature(ResultSetMetaData metaData) |
protected static org.apache.calcite.avatica.Meta.Signature |
signature(ResultSetMetaData metaData,
ParameterMetaData parameterMetaData,
String sql,
org.apache.calcite.avatica.Meta.StatementType statementType) |
boolean |
syncResults(org.apache.calcite.avatica.Meta.StatementHandle sh,
org.apache.calcite.avatica.QueryState state,
long offset) |
public static final int UNLIMITED_COUNT
Statement#getLargeMaxRows()
that means fetch
an unlimited number of rows in a single batch.
Any other negative value will return an unlimited number of rows but will do it in the default batch size, namely 100.
public JdbcMeta(String url) throws SQLException
url
- a database url of the form
jdbc:subprotocol:subname
SQLException
public JdbcMeta(String url, String user, String password) throws SQLException
url
- a database url of the form
jdbc:subprotocol:subname
user
- the database user on whose behalf the connection is being
madepassword
- the user's passwordSQLException
public JdbcMeta(String url, Properties info) throws SQLException
SQLException
public JdbcMeta(String url, Properties info, org.apache.calcite.avatica.metrics.MetricsSystem metrics) throws SQLException
url
- a database url of the form
jdbc:subprotocol:subname
info
- a list of arbitrary string tag/value pairs as
connection arguments; normally at least a "user" and
"password" property should be includedSQLException
protected AtomicInteger getStatementIdGenerator()
protected com.google.common.cache.Cache<String,Connection> getConnectionCache()
protected com.google.common.cache.Cache<Integer,StatementInfo> getStatementCache()
protected static List<org.apache.calcite.avatica.ColumnMetaData> columns(ResultSetMetaData metaData) throws SQLException
SQLException
protected static List<org.apache.calcite.avatica.AvaticaParameter> parameters(ParameterMetaData metaData) throws SQLException
SQLException
protected static org.apache.calcite.avatica.Meta.Signature signature(ResultSetMetaData metaData, ParameterMetaData parameterMetaData, String sql, org.apache.calcite.avatica.Meta.StatementType statementType) throws SQLException
SQLException
protected static org.apache.calcite.avatica.Meta.Signature signature(ResultSetMetaData metaData) throws SQLException
SQLException
public Map<org.apache.calcite.avatica.Meta.DatabaseProperty,Object> getDatabaseProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
getDatabaseProperties
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, List<String> typeList)
getTables
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
getColumns
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern)
getSchemas
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
getCatalogs
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getTableTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
getTableTypes
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getProcedures(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat procedureNamePattern)
getProcedures
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getProcedureColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat procedureNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
getProcedureColumns
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getColumnPrivileges(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
getColumnPrivileges
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getTablePrivileges(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern)
getTablePrivileges
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getBestRowIdentifier(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table, int scope, boolean nullable)
getBestRowIdentifier
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getVersionColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table)
getVersionColumns
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getPrimaryKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table)
getPrimaryKeys
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getImportedKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table)
getImportedKeys
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getExportedKeys(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table)
getExportedKeys
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getCrossReference(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String parentCatalog, String parentSchema, String parentTable, String foreignCatalog, String foreignSchema, String foreignTable)
getCrossReference
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getTypeInfo(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
getTypeInfo
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getIndexInfo(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, String schema, String table, boolean unique, boolean approximate)
getIndexInfo
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getUDTs(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat typeNamePattern, int[] types)
getUDTs
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getSuperTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat typeNamePattern)
getSuperTypes
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getSuperTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern)
getSuperTables
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getAttributes(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat typeNamePattern, org.apache.calcite.avatica.Meta.Pat attributeNamePattern)
getAttributes
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getClientInfoProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
getClientInfoProperties
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getFunctions(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat functionNamePattern)
getFunctions
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getFunctionColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat functionNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
getFunctionColumns
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.MetaResultSet getPseudoColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
getPseudoColumns
in interface org.apache.calcite.avatica.Meta
public Iterable<Object> createIterable(org.apache.calcite.avatica.Meta.StatementHandle handle, org.apache.calcite.avatica.QueryState state, org.apache.calcite.avatica.Meta.Signature signature, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, org.apache.calcite.avatica.Meta.Frame firstFrame)
createIterable
in interface org.apache.calcite.avatica.Meta
protected Connection getConnection(String id) throws SQLException
SQLException
public org.apache.calcite.avatica.Meta.StatementHandle createStatement(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
createStatement
in interface org.apache.calcite.avatica.Meta
public void closeStatement(org.apache.calcite.avatica.Meta.StatementHandle h)
closeStatement
in interface org.apache.calcite.avatica.Meta
public void openConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch, Map<String,String> info)
openConnection
in interface org.apache.calcite.avatica.Meta
protected Connection createConnection(String url, Properties info) throws SQLException
SQLException
public void closeConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
closeConnection
in interface org.apache.calcite.avatica.Meta
protected void apply(Connection conn, org.apache.calcite.avatica.Meta.ConnectionProperties connProps) throws SQLException
SQLException
public org.apache.calcite.avatica.Meta.ConnectionProperties connectionSync(org.apache.calcite.avatica.Meta.ConnectionHandle ch, org.apache.calcite.avatica.Meta.ConnectionProperties connProps)
connectionSync
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.StatementHandle prepare(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String sql, long maxRowCount)
prepare
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h, String sql, long maxRowCount, org.apache.calcite.avatica.Meta.PrepareCallback callback) throws org.apache.calcite.avatica.NoSuchStatementException
prepareAndExecute
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h, String sql, long maxRowCount, int maxRowsInFirstFrame, org.apache.calcite.avatica.Meta.PrepareCallback callback) throws org.apache.calcite.avatica.NoSuchStatementException
prepareAndExecute
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public boolean syncResults(org.apache.calcite.avatica.Meta.StatementHandle sh, org.apache.calcite.avatica.QueryState state, long offset) throws org.apache.calcite.avatica.NoSuchStatementException
syncResults
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public org.apache.calcite.avatica.Meta.Frame fetch(org.apache.calcite.avatica.Meta.StatementHandle h, long offset, int fetchMaxRowCount) throws org.apache.calcite.avatica.NoSuchStatementException, org.apache.calcite.avatica.MissingResultsException
fetch
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
org.apache.calcite.avatica.MissingResultsException
public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle h, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, long maxRowCount) throws org.apache.calcite.avatica.NoSuchStatementException
execute
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle h, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, int maxRowsInFirstFrame) throws org.apache.calcite.avatica.NoSuchStatementException
execute
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public void commit(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
commit
in interface org.apache.calcite.avatica.Meta
public void rollback(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
rollback
in interface org.apache.calcite.avatica.Meta
public org.apache.calcite.avatica.Meta.ExecuteBatchResult prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle h, List<String> sqlCommands) throws org.apache.calcite.avatica.NoSuchStatementException
prepareAndExecuteBatch
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public org.apache.calcite.avatica.Meta.ExecuteBatchResult executeBatch(org.apache.calcite.avatica.Meta.StatementHandle h, List<List<org.apache.calcite.avatica.remote.TypedValue>> updateBatches) throws org.apache.calcite.avatica.NoSuchStatementException
executeBatch
in interface org.apache.calcite.avatica.Meta
org.apache.calcite.avatica.NoSuchStatementException
public org.apache.calcite.avatica.Meta.ExecuteBatchResult executeBatchProtobuf(org.apache.calcite.avatica.Meta.StatementHandle h, List<org.apache.calcite.avatica.proto.Requests.UpdateBatch> updateBatches) throws org.apache.calcite.avatica.NoSuchStatementException
executeBatchProtobuf
in interface org.apache.calcite.avatica.remote.ProtobufMeta
org.apache.calcite.avatica.NoSuchStatementException
Copyright © 2012-2019 Apache Software Foundation. All Rights Reserved.