|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
DbFactory defines all the interface methods that any Adb-like client needs to implement to supply the instances of their DbXXXXXXX interface implementations. This class is the single source for object creation. Application clients can set/get their particular choice of DbFactory implementation through the static methods of the DbManager class.
Method Summary | |
DbOpcode |
getDeleteOpcode()
Get an instance of a DbOpcode object that represents a Delete operation. |
DbOpcode |
getInsertOpcode()
Get an instance of a DbOpcode object that represents an Insert operation. |
DbOpcode |
getOpcode(int opCode)
Get the OpCode object corresponding to an integer opcode. |
DbPubMsg |
getPubMsg(com.tibco.tibrv.TibrvMsg rvMsg)
Get an instance of a PubMsg object constructed from a Tibrv message. |
DbReply |
getReply(com.tibco.tibrv.TibrvMsg replyMsg)
Get an instance of a DbReply object. |
DbRequest |
getRequest(DbRequestStmt stmt)
Get an instance of a DbRequest object. |
DbRequest |
getRequest(DbRequestStmt[] stmts)
Get an instance of a DbRequest object. |
DbRequest |
getRequest(DbRequestStmt[] stmts,
double timeout)
Get an instance of a DbRequest object. |
DbRequest |
getRequest(DbRequestStmt[] stmts,
double timeout,
java.lang.Object closure)
Get an instance of a DbRequest object. |
DbRequest |
getRequest(DbRequestStmt stmt,
double timeout)
Get an instance of a DbRequest object. |
DbRequest |
getRequest(DbRequestStmt stmt,
double timeout,
java.lang.Object closure)
Get an instance of a DbRequest object. |
DbRequestBind |
getRequestBind(int position,
java.lang.Object data)
Get an instance of a DbRequestStmt object. |
DbRequestBind |
getRequestBind(int position,
java.lang.String column,
java.lang.Object data)
Get an instance of a DbRequestStmt object. |
DbRequestBind |
getRequestBind(java.lang.String column,
java.lang.Object data)
Get an instance of a DbRequestStmt object. |
DbRequestStmt |
getRequestStmt(java.lang.String sql)
Get an instance of a DbRequestStmt object. |
DbRequestStmt |
getRequestStmt(java.lang.String sql,
DbRequestBind bind)
Get an instance of a DbRequestStmt object |
DbRequestStmt |
getRequestStmt(java.lang.String sql,
DbRequestBind[] binds)
Get an instance of a DbRequestStmt object |
DbRequestStmt |
getRequestStmt(java.lang.String sql,
DbRequestBind[] binds,
int maxRows)
Get an instance of a DbRequestStmt object |
DbRequestStmt |
getRequestStmt(java.lang.String sql,
DbRequestBind bind,
int maxRows)
Get an instance of a DbRequestStmt object |
DbRequestStmt |
getRequestStmt(java.lang.String sql,
int maxRows)
Get an instance of a DbRequestStmt object. |
DbOpcode |
getUnknownOpcode()
Get an instance of a DbOpcode object that represents an Unknown operation. |
DbOpcode |
getUpdateOpcode()
Get an instance of a DbOpcode object that represents an Update operation. |
DbOpcode |
getUpsertOpcode()
Get an instance of a DbOpcode object that represents an Upsert operation. |
Method Detail |
public DbRequest getRequest(DbRequestStmt stmt)
stmt
- request statementDbRequestStmt
public DbRequest getRequest(DbRequestStmt stmt, double timeout)
stmt
- Request statement.timeout
- Maximum time interval - in seconds - for which to
wait for reply in request/reply mode.DbRequest.sendRequest(TibrvTransport, String)
,
DbRequest.sendRequest(String)
,
DbRequestStmt
public DbRequest getRequest(DbRequestStmt stmt, double timeout, java.lang.Object closure)
stmt
- Request statement.timeout
- Maximum time interval - in seconds - for which to
wait for reply in request/reply mode.closure
- Closure argument.DbRequest.sendRequest(TibrvTransport, String)
,
DbRequest.sendRequest(String)
,
DbRequestStmt
public DbRequest getRequest(DbRequestStmt[] stmts)
stmts
- Request statements.DbRequestStmt
public DbRequest getRequest(DbRequestStmt[] stmts, double timeout)
stmts
- Request statements.timeout
- Maximum time interval - in seconds - for which to
wait for reply in request/reply mode.DbRequest.sendRequest(TibrvTransport, String)
,
DbRequest.sendRequest(String)
,
DbRequestStmt
public DbRequest getRequest(DbRequestStmt[] stmts, double timeout, java.lang.Object closure)
stmts
- Request statements.timeout
- Maximum time interval - in seconds - for which to
wait for reply in request/reply mode.closure
- Closure argument.DbRequest.sendRequest(TibrvTransport, String)
,
DbRequest.sendRequest(String)
,
DbRequestStmt
public DbReply getReply(com.tibco.tibrv.TibrvMsg replyMsg)
replyMsg
- Reply message from ADB.public DbRequestStmt getRequestStmt(java.lang.String sql)
sql
- The SQL statement to execute on the ADB.public DbRequestStmt getRequestStmt(java.lang.String sql, int maxRows)
sql
- The SQL statement to execute on the ADB.maxRows
- Maximum number of result rows returned from request.public DbRequestStmt getRequestStmt(java.lang.String sql, DbRequestBind bind)
sql
- The SQL statement to execute on the ADB.bind
- Bind data.DbRequestBind
public DbRequestStmt getRequestStmt(java.lang.String sql, DbRequestBind bind, int maxRows)
sql
- The SQL statement to execute on the ADB.bind
- Bind data.maxRows
- Maximum number of result rows returned from request.DbRequestBind
public DbRequestStmt getRequestStmt(java.lang.String sql, DbRequestBind[] binds)
sql
- The SQL statement to execute on the ADB.binds
- Bind data.DbRequestBind
public DbRequestStmt getRequestStmt(java.lang.String sql, DbRequestBind[] binds, int maxRows)
sql
- The SQL statement to execute on the ADB.binds
- Bind data.maxRows
- Maximum number of result rows returned from request.DbRequestBind
public DbRequestBind getRequestBind(int position, java.lang.String column, java.lang.Object data)
position
- Placeholder position.column
- Column name.data
- Column data.public DbRequestBind getRequestBind(java.lang.String column, java.lang.Object data)
column
- Column name.data
- Column data.public DbRequestBind getRequestBind(int position, java.lang.Object data)
position
- Placeholder position.data
- Column data.public DbOpcode getInsertOpcode()
public DbOpcode getDeleteOpcode()
public DbOpcode getUpdateOpcode()
public DbOpcode getUpsertOpcode()
public DbOpcode getUnknownOpcode()
public DbOpcode getOpcode(int opCode)
opCode
- an application specific opcode value as an integerpublic DbPubMsg getPubMsg(com.tibco.tibrv.TibrvMsg rvMsg)
rvMsg
- the rvMsg that is published
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |