public abstract class X100Connector extends Object implements IX100Connector
Modifier and Type | Field and Description |
---|---|
protected long |
connectionID |
protected String |
dbName |
protected String |
hostName |
static Object |
initBlockLock |
static String |
JDBC_INGRES_PREFIX |
static org.apache.commons.logging.Log |
LOG |
protected int[] |
paxGroupList |
protected static ConcurrentHashMap<String,int[]> |
paxGroupMap |
protected String |
port |
protected String |
pwd |
protected String |
tableName |
protected long |
tabPaxInfo |
protected String |
url |
protected String |
userName |
Constructor and Description |
---|
X100Connector(String host,
String port,
String dbName,
String tableName,
String user,
String password) |
X100Connector(String host,
String port,
String dbName,
String tableName,
String user,
String password,
String schema) |
Modifier and Type | Method and Description |
---|---|
int |
closePax(long paxIter) |
int |
closePaxGroup(long paGrpPtr) |
protected int |
commit(int connection) |
void |
disconnect()
This method should be called to close the connection
|
String |
getColumnName(int index)
This method fetches the columnname for a given index
|
int[] |
getColumnsForPaxGroup(int paxGrp)
Fetches number of columns for a given paxGroupID
|
String |
getColumnType(int index)
This method fetches the columnname for a given index
|
long |
getConnectionID()
Returns the connectionID associated with this object
|
int |
getNumCols()
Fetches the number of columns in a table
|
int |
getNumPaxGroups()
This method fetches the number of paxGroups for a given connection
|
int |
getPaxGroupByColumn(int columnName)
This method fetches paxGroup number for a given coulmn index
|
int[] |
getPaxGroupsInfo()
Fetches paxGroupInfo from x100Server for this connection
|
String |
getTableName() |
long |
getTabPaxInfo(String tab) |
long |
getX100DataType(int paxId) |
boolean |
isCoulmnNullable(int index)
This method fetches the columnname for a given index
|
long |
openPax(String tab,
int paxNo,
int partNo) |
long |
openPaxGroup(long tabPaxInfo,
int paxNo) |
int |
parallelCommit(int jobID)
Issues a parallel commit
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAPIVersion, getSortKeys, getSortKeySize, getTupleCount, getUniqueKeys, getUniqueKeySize, initParallelCommit, initParallelCommit
protected String hostName
protected String dbName
protected String tableName
protected String port
protected String userName
protected String url
protected String pwd
protected static ConcurrentHashMap<String,int[]> paxGroupMap
protected int[] paxGroupList
protected long connectionID
protected long tabPaxInfo
public static final String JDBC_INGRES_PREFIX
public static final org.apache.commons.logging.Log LOG
public static final Object initBlockLock
public X100Connector(String host, String port, String dbName, String tableName, String user, String password) throws ConnectionException
ConnectionException
public X100Connector(String host, String port, String dbName, String tableName, String user, String password, String schema) throws ConnectionException
ConnectionException
public String getTableName()
public void disconnect()
disconnect
in interface IX100Connector
protected int commit(int connection)
public long openPaxGroup(long tabPaxInfo, int paxNo)
openPaxGroup
in interface IX100Connector
public long getTabPaxInfo(String tab)
getTabPaxInfo
in interface IX100Connector
public long openPax(String tab, int paxNo, int partNo)
openPax
in interface IX100Connector
public int closePaxGroup(long paGrpPtr)
closePaxGroup
in interface IX100Connector
public int closePax(long paxIter)
closePax
in interface IX100Connector
public int parallelCommit(int jobID)
parallelCommit
in interface IX100Connector
clientID
- -- JobID for which the commit is being issuedpublic int getPaxGroupByColumn(int columnName)
columnNumber
- -- index of the column in tablepublic int getNumPaxGroups()
getNumPaxGroups
in interface IX100Connector
public int[] getColumnsForPaxGroup(int paxGrp)
getColumnsForPaxGroup
in interface IX100Connector
paxGrp
- -- pax group numberpublic int getNumCols()
public int[] getPaxGroupsInfo()
getPaxGroupsInfo
in interface IX100Connector
public String getColumnName(int index)
getColumnName
in interface IX100Connector
index
- -- column indexpublic String getColumnType(int index)
getColumnType
in interface IX100Connector
index
- -- column indexpublic long getX100DataType(int paxId)
getX100DataType
in interface IX100Connector
public boolean isCoulmnNullable(int index)
isCoulmnNullable
in interface IX100Connector
index
- -- column indexpublic long getConnectionID()
getConnectionID
in interface IX100Connector
Copyright © 2016 Actian Corporation. All Rights Reserved.