SqlNetworkHandler Class Reference

#include <SqlNetworkHandler.h>

Collaboration diagram for SqlNetworkHandler:

[legend]

Public Member Functions
int	process (PacketHeader &header, char *buffer)
int	processPrepare (PacketHeader &header, char *buffer)
int	processCommit (PacketHeader &header, char *buffer)
int	processFree (PacketHeader &header, char *buffer)
Static Public Attributes
static List	stmtList
static AbsSqlConnection *	conn
static SqlApiImplType	type

---

Detailed Description

Definition at line 26 of file SqlNetworkHandler.h.

---

Member Function Documentation

int SqlNetworkHandler::process	(	PacketHeader &	header,
		char *	buffer
	)

Definition at line 34 of file SqlNetworkHandler.cxx.

References NW_PKT_COMMIT, NW_PKT_PREPARE, PacketHeader::packetType, processCommit(), and processPrepare().

Referenced by UDPServer::handleClient().

{
    switch(header.packetType)
    {
        case NW_PKT_PREPARE:
            return processPrepare(header, buffer);
            break;
        case NW_PKT_COMMIT:
            return processCommit(header, buffer);
            break;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

int SqlNetworkHandler::processCommit	(	PacketHeader &	header,
		char *	buffer
	)

Definition at line 47 of file SqlNetworkHandler.cxx.

References DM_Network, ErrSysFatal, PacketCommit::getExecPacketList(), OK, PacketHeader::packetLength, printDebug, printError, BasePacket::setBuffer(), BasePacket::setBufferSize(), stmtList, and PacketCommit::unmarshall().

Referenced by process().

{
    printDebug(DM_Network, "Processing COMMIT");
    PacketCommit *pkt = new PacketCommit();
    pkt->setBuffer(buffer);
    pkt->setBufferSize(header.packetLength);
    pkt->unmarshall();
    List pktList;
    pkt->getExecPacketList(stmtList, pktList);
    DbRetVal rv = applyExecPackets(stmtList, pktList);
    int response = 1;
    if (rv != OK)
    {
         printError(ErrSysFatal, "Unable to apply the exec packets\n");
         response =0;
    }
    return response;

}

Here is the call graph for this function:

Here is the caller graph for this function:

int SqlNetworkHandler::processFree	(	PacketHeader &	header,
		char *	buffer
	)

Definition at line 66 of file SqlNetworkHandler.cxx.

References PacketHeader::packetLength, BasePacket::setBuffer(), BasePacket::setBufferSize(), and PacketFree::unmarshall().

{
    PacketFree *pkt = new PacketFree();
    pkt->setBuffer(buffer);
    pkt->setBufferSize(header.packetLength);
    pkt->unmarshall();
    //printf("FREE %d \n", pkt->stmtID);
    int response =1;
    //This wont work for two statement executed in same transaction using same SqlStatement object using free.
    //so do not delete now and put a flag 'readyfordelete' in NetworkStmt object and delete it during execute
    /*
    ListIterator iter = stmtList.getIterator();
    NetworkStmt *stmt, *removeStmt = NULL;
    while (iter.hasElement())
    {
       stmt = (NetworkStmt*)iter.nextElement();
       if (stmt->srcNetworkID == header.srcNetworkID
                && stmt->stmtID == pkt->stmtID)
       {
                  removeStmt = stmt;
                  break;
       }
    }
    if (removeStmt) stmtList.remove(removeStmt);
    else printf("Statement id %d not found in list \n",  pkt->stmtID);
    */
    return response;
}

Here is the call graph for this function:

int SqlNetworkHandler::processPrepare	(	PacketHeader &	header,
		char *	buffer
	)

Definition at line 94 of file SqlNetworkHandler.cxx.

References AllDataType::alloc(), List::append(), conn, SqlFactory::createStatement(), DM_Network, ErrSysInit, PacketPrepare::length, BindSqlField::length, PacketPrepare::noParams, OK, PacketHeader::packetLength, NetworkStmt::paramList, AbsSqlStatement::prepare(), printDebug, printError, BasePacket::setBuffer(), BasePacket::setBufferSize(), AbsSqlStatement::setConnection(), PacketHeader::srcNetworkID, NetworkStmt::srcNetworkID, NetworkStmt::stmt, NetworkStmt::stmtID, PacketPrepare::stmtID, stmtList, PacketPrepare::stmtString, PacketPrepare::type, BindSqlField::type, type, PacketPrepare::unmarshall(), and BindSqlField::value.

Referenced by process().

{
    PacketPrepare *pkt = new PacketPrepare();
    pkt->setBuffer(buffer);
    pkt->setBufferSize(header.packetLength);
    pkt->unmarshall();
    printDebug(DM_Network, "PREPARE %d %s\n", pkt->stmtID, pkt->stmtString);
    //for (int i =0 ; i < pkt->noParams; i++)
        //printf("PREPARE type %d length %d \n", pkt->type[i], pkt->length[i]);
    int response =1;
    //TODO::add it to the SqlStatement list
    AbsSqlStatement *sqlstmt = SqlFactory::createStatement(type);
    sqlstmt->setConnection(conn);
    NetworkStmt *nwStmt = new NetworkStmt();
    printDebug(DM_Network, "Statement string %s\n", pkt->stmtString);
    nwStmt->srcNetworkID = header.srcNetworkID;
    nwStmt->stmtID =  pkt->stmtID;
    nwStmt->stmt = sqlstmt;
    DbRetVal rv = sqlstmt->prepare(pkt->stmtString);
    if (rv != OK)
    {
        printError(ErrSysInit, "statement prepare failed\n");
        response = 0;
        return response;
    }
    BindSqlField *bindField = NULL;
    //populate paramList
    for (int i = 0; i < pkt->noParams; i++)
    {
             bindField = new BindSqlField();
             bindField->type = (DataType) pkt->type[i];
             bindField->length = pkt->length[i];
             bindField->value = AllDataType::alloc(bindField->type, 
                                                   bindField->length);
             nwStmt->paramList.append(bindField);
    }
    stmtList.append(nwStmt);
    return response;

}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Field Documentation

AbsSqlConnection * SqlNetworkHandler::conn [static]

Definition at line 35 of file SqlNetworkHandler.h.

Referenced by main(), and processPrepare().

List SqlNetworkHandler::stmtList [static]

Definition at line 34 of file SqlNetworkHandler.h.

Referenced by processCommit(), and processPrepare().

SqlApiImplType SqlNetworkHandler::type [static]

Definition at line 36 of file SqlNetworkHandler.h.

Referenced by main(), and processPrepare().

---

The documentation for this class was generated from the following files:

• include/SqlNetworkHandler.h
• src/network/SqlNetworkHandler.cxx

---