src/tools/isql.cxx File Reference

#include <CSql.h>
#include <DatabaseManagerImpl.h>
#include <Statement.h>
#include <SqlFactory.h>
#include <SqlStatement.h>

Include dependency graph for isql.cxx:

Go to the source code of this file.

Defines
#define	SQL_STMT_LEN   1024
Enumerations
enum	STMT_TYPE { SELECT = 0, DDL, OTHER }
Functions
void	printHelp ()
bool	getInput (bool)
void	printUsage ()
int	main (int argc, char **argv)
bool	handleTransaction (char *st)
bool	handleEchoAndComment (char *st)
void	setStmtType (char *st)
char	getQueryFromStdIn (char *buf)
char	getQueryFromFile (char *buf)
Variables
STMT_TYPE	stmtType = SELECT
FILE *	fp
AbsSqlConnection *	conn
AbsSqlStatement *	stmt
bool	gateway = false
bool	silent = false
bool	autocommitmode = true
IsolationLevel	isoLevel = READ_COMMITTED

---

Define Documentation

#define SQL_STMT_LEN   1024

Definition at line 21 of file isql.cxx.

Referenced by getInput(), getQueryFromFile(), and getQueryFromStdIn().

---

Enumeration Type Documentation

enum STMT_TYPE

Enumerator:

SELECT
DDL
OTHER

Definition at line 22 of file isql.cxx.

{
    SELECT =0,
    DDL ,
    OTHER
};

---

Function Documentation

bool getInput

(

bool

)

Definition at line 285 of file isql.cxx.

References autocommitmode, AbsSqlStatement::close(), Connection::commit(), conn, DDL, AbsSqlStatement::execute(), AbsSqlStatement::fetchAndPrint(), FieldInfo::fldName, AbsSqlStatement::free(), AbsSqlStatement::getProjFldInfo(), getQueryFromFile(), getQueryFromStdIn(), handleEchoAndComment(), handleTransaction(), isoLevel, AbsSqlStatement::noOfProjFields(), OK, OTHER, AbsSqlStatement::prepare(), setStmtType(), silent, SQL_STMT_LEN, stmt, and stmtType.

Referenced by main().

{
    char buffer [SQL_STMT_LEN + 1];

    char eof;
    if (fromFile == false)
        eof = getQueryFromStdIn(buffer);
    else
        eof = getQueryFromFile(buffer);
                     
    char *buf = buffer;
    while(*buf == ' ' || *buf == '\t' || *buf == '\n') buf++;
    if (eof == EOF || strncasecmp (buf, "quit", 4) == 0)
        return false;
    if (handleTransaction(buf)) return true;
    if (handleEchoAndComment(buf)) return true;
    if ( *buf == ';' ) return true; // Null statement.
    
    setStmtType(buf);

    DbRetVal rv = stmt->prepare(buf);
    if (rv != OK) 
    {
        printf("Statement prepare failed with error %d\n", rv); 
        return true; 
    }
    int rows =0;
    rv = stmt->execute(rows);
    if (rv != OK) 
    {
        printf("Statement execute failed with error %d\n", rv);
        stmt->free();
        return true; 
    }
    if (stmtType == OTHER)
    {
        if (!silent) printf("Statement Executed: Rows Affected = %d\n", rows);
    }
    else if (stmtType == DDL)
    {
        if (!silent) printf("Statement Executed\n");
    }
    else
    {
        FieldInfo *info = new FieldInfo();
        printf("---------------------------------------------------------\n");
        printf("\t");
        for (int i = 0 ; i < stmt->noOfProjFields() ; i++)
        {
            stmt->getProjFldInfo(i, info);
            printf("%s\t", info->fldName);
        }
        printf("\n---------------------------------------------------------\n");
        delete info;
        void *tuple = NULL;
        while(true)
        {
            printf("\t");
            tuple = (char*)stmt->fetchAndPrint(false);
            printf("\n");
            if (tuple == NULL) { break; }
        }
        stmt->close();
    }
    stmt->free();
    if (autocommitmode)
    {
        conn->commit();
        //conn->beginTrans(isoLevel, TSYNC);
        conn->beginTrans(isoLevel);
        return true;
    }
    return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

char getQueryFromFile

(

char *

buf

)

Definition at line 265 of file isql.cxx.

References fp, and SQL_STMT_LEN.

Referenced by getInput().

{
    char    c, *bufBegin=buf;
    int charCnt=0;
    while( (c=(char ) fgetc(fp)) != EOF && c != ';')
    {
        *buf++ = c; charCnt++; 
        if( charCnt == SQL_STMT_LEN ) {
            printf("SQL Statement length is greater than %d. "
            "Ignoring the statement.\n", SQL_STMT_LEN );
            *bufBegin++ =';';
            *bufBegin ='\0';
            return 0;
        }
    }
    *buf++ = ';';
    *buf = '\0';
    return c;
}

Here is the caller graph for this function:

char getQueryFromStdIn

(

char *

buf

)

Definition at line 240 of file isql.cxx.

References SQL_STMT_LEN.

Referenced by getInput().

{
    char    c, *bufBegin=buf;
    int    ln, charCnt=0;

    ln=1;
    printf("CSQL>");
    while( (c=(char ) getchar()) != EOF && c != ';')
    {
        *buf++ = c; charCnt++;
        if(c=='\n') //printf("%1d>",ln++);
            ln++;

        if( charCnt == SQL_STMT_LEN ) {
            printf("SQL Statement length is greater than %d. "
            "Ignoring the statement.\n", SQL_STMT_LEN );
            *bufBegin++ =';';
            *bufBegin ='\0';
            return 0;
        }
    }
    *buf++ = ';';
    *buf = '\0';
    return c;
}

Here is the caller graph for this function:

bool handleEchoAndComment

(

char *

st

)

Definition at line 174 of file isql.cxx.

References Connection::close(), conn, DatabaseManagerImpl::getAllTableNames(), Connection::getDatabaseManager(), List::getIterator(), ListIterator::hasElement(), Identifier::name, ListIterator::nextElement(), Connection::open(), and printHelp().

Referenced by getInput().

{
    while (isspace (*st)|| *st == '(' ) st++; // Skip white spaces
    if (strncasecmp (st, "ECHO", 4) == 0)
    {
        printf("%s\n", st);
        return true;
    }else if (strncmp(st, "--", 2) == 0)
    {
        return true;
    }else if (strncasecmp(st, "help", 2) == 0)
    {
        printHelp();
        return true;
    }else if (strncasecmp(st, "show tables", 11) == 0)
    {
      Connection conn;
      conn.open("root","manager");
      DatabaseManagerImpl *dbMgr =  (DatabaseManagerImpl*)conn.getDatabaseManager();
      if (dbMgr == NULL)
      {
          printf("Unable to connect to csql server\n");
          return true;
      }
      List tableList = dbMgr->getAllTableNames();
      ListIterator iter = tableList.getIterator();
      Identifier *elem = NULL;
      int ret =0;
      printf("=============TableNames===================\n");
      int count =0;
      while (iter.hasElement())
      {
          elem = (Identifier*) iter.nextElement();
          count++;
          printf("   %s \n", elem->name);
      }
      if (count ==0) printf("  No tables exist\n");
      printf("=========================================\n");
      conn.close();
      return true;
    }
    return false;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool handleTransaction

(

char *

st

)

Definition at line 123 of file isql.cxx.

References autocommitmode, Connection::commit(), conn, isoLevel, READ_COMMITTED, READ_REPEATABLE, READ_UNCOMMITTED, Connection::rollback(), and silent.

Referenced by getInput().

{
    while (isspace (*st)|| *st == '(' ) st++; // Skip white spaces
    if (strncasecmp (st, "COMMIT", 6) == 0 ||
        strncasecmp (st, "commit", 6) == 0 )
    {
        conn->commit();
        //conn->beginTrans(isoLevel, TSYNC);
        conn->beginTrans(isoLevel);
        return true;
    }
    else if (strncasecmp (st, "ROLLBACK", 8) == 0|| 
        strncasecmp (st, "rollback", 8) == 0)
    {
        conn->rollback();
        //conn->beginTrans(isoLevel, TSYNC);
        conn->beginTrans(isoLevel);
        return true;
    }
    else if (strncasecmp (st, "SET AUTOCOMMIT ON", 17) == 0)
    {
        autocommitmode = true;
        if (!silent) printf("AUTOCOMMIT Mode is set to ON\n");
        return true;
    }
    else if (strncasecmp (st, "SET AUTOCOMMIT OFF", 18) == 0)
    {
        autocommitmode = false;
        if (!silent) printf("AUTOCOMMIT Mode is set to OFF\n");
        return true;
    }
    else if (strncasecmp (st, "SET ISOLATION LEVEL UNCOMMITTED", 31) == 0)
    {
        isoLevel = READ_UNCOMMITTED;
        printf("Isolation Level is set to READ_UNCOMMITTED\n");
        return true;
    }
    else if (strncasecmp (st, "SET ISOLATION LEVEL COMMITTED", 29) == 0)
    {
        isoLevel = READ_COMMITTED;
        printf("Isolation Level is set to READ_COMMITTED\n");
        return true;
    }
    else if (strncasecmp (st, "SET ISOLATION LEVEL REPEATABLE", 30) == 0)
    {
        isoLevel = READ_REPEATABLE;
        printf("Isolation Level is set to READ_REPEATABLE\n");
        return true;
    }
    return false;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int main	(	int	argc,
		char **	argv
	)

Definition at line 48 of file isql.cxx.

References conn, SqlFactory::createConnection(), SqlFactory::createStatement(), CSql, CSqlGateway, fp, gateway, getInput(), IDENTIFIER_LENGTH, OK, printUsage(), Connection::rollback(), AbsSqlStatement::setConnection(), silent, and stmt.

{
    char username[IDENTIFIER_LENGTH];
    username [0] = '\0';
    char password[IDENTIFIER_LENGTH];
    password [0] = '\0';
    char filename[512];
    filename [0] ='\0';
    int c = 0, opt=0;
    while ((c = getopt(argc, argv, "u:p:s:gS?")) != EOF) 
    {
        switch (c)
        {
            case 'u' : strcpy(username , argv[optind - 1]); break;
            case 'p' : strcpy(password , argv[optind - 1]); break;
            case 's' : strcpy(filename , argv[optind - 1]); break;
            case '?' : { opt = 1; break; } //print help 
            case 'S' : { silent = true; break; } //silent 
            case 'g' : { gateway = true; break; } //print help 
            default: printf("Wrong args\n"); exit(1);

        }
    }//while options
    //printf("%s %s %s", username, password, filename);
    if (opt == 1)
    {
        printUsage();
        return 0;
    }
    if (username[0] == '\0' )
    {
        strcpy(username, "root");
        strcpy(password, "manager");
    }
    bool fileFlag = false;
    if (filename [0] !='\0')
    {
        fp = fopen(filename,"r");
        if (fp == NULL)
        {
            printf("Unable to open the file %s\n", filename);
            return 1;
        }
        fileFlag = true;
    }
    
    DbRetVal rv = OK;
    if (gateway)
      conn = SqlFactory::createConnection(CSqlGateway);
    else
      conn = SqlFactory::createConnection(CSql);
    rv = conn->connect(username,password);
    if (rv != OK) return 1;
    if (gateway)
      stmt =  SqlFactory::createStatement(CSqlGateway);
    else
      stmt =  SqlFactory::createStatement(CSql);
    stmt->setConnection(conn);
    //rv = conn->beginTrans(READ_COMMITTED, TSYNC);
    rv = conn->beginTrans();
    if (rv != OK) return 2;
    while (getInput(fileFlag) == true) continue;

    //TODO::conn should provide method telling status of the transaction.
    //if running, then abort it
    conn->rollback();
    if (filename [0] !='\0')
    {
       fclose(fp);
    }
    conn->disconnect();
    delete stmt;
    delete conn;
    return 0;
}

Here is the call graph for this function:

void printHelp

(

)

Definition at line 217 of file isql.cxx.

Referenced by handleEchoAndComment().

{
    printf("CSQL Command List\n");
    printf("======================================================\n");
    printf("SHOW TABLES\n");
    printf("SET AUTOCOMMIT ON|OFF\n");
    printf("SET ISOLATION LEVEL UNCOMMITTED|COMMITTED|REPEATABLE\n");
    printf("CREATE TABLE|INDEX ...\n");
    printf("INSERT ...\n");
    printf("UPDATE ...\n");
    printf("DELETE ...\n");
    printf("SELECT ...\n");
    printf("======================================================\n");
}

Here is the caller graph for this function:

void printUsage

(

)

Definition at line 38 of file isql.cxx.

{
   printf("Usage: csql [-u username] [-p passwd] [-s sqlfile] \n");
   printf("       username -> username to connect to database\n");
   printf("       password -> password to connect to database\n");
   printf("       sqlfile -> filename containing sql statements\n");
   return;
  
}

void setStmtType

(

char *

st

)

Definition at line 231 of file isql.cxx.

References DDL, OTHER, SELECT, and stmtType.

Referenced by getInput().

{
   if (strncasecmp (st, "SELECT", 6) == 0)  {stmtType=SELECT; return; }
   else if (strncasecmp (st, "CREATE", 6) == 0) {stmtType=DDL; return; }
   else if (strncasecmp (st, "DROP", 4) == 0) { stmtType=DDL; return; }
   stmtType = OTHER;
   return ;
}

Here is the caller graph for this function:

---

Variable Documentation

bool autocommitmode = true

Definition at line 34 of file isql.cxx.

Referenced by getInput(), and handleTransaction().

AbsSqlConnection* conn

Definition at line 30 of file isql.cxx.

FILE* fp

Definition at line 29 of file isql.cxx.

Referenced by CacheTableLoader::addToCacheTableFile(), getQueryFromFile(), isCached(), main(), NetworkTable::readNetworkConfig(), CacheTableLoader::recoverAllCachedTables(), and CacheTableLoader::removeFromCacheTableFile().

bool gateway = false

Definition at line 33 of file isql.cxx.

Referenced by main().

IsolationLevel isoLevel = READ_COMMITTED

Definition at line 35 of file isql.cxx.

Referenced by SqlConnection::beginTrans(), getInput(), and handleTransaction().

bool silent = false

Definition at line 33 of file isql.cxx.

Referenced by getInput(), handleTransaction(), and main().

AbsSqlStatement* stmt

Definition at line 31 of file isql.cxx.

Referenced by copyFromOdbc(), SqlFactory::createStatement(), SelStatement::fetchAndPrint(), getInput(), getRecordsFromTargetDb(), StatementFactory::getStatement(), insert(), Java_csql_jdbc_JSqlStatement_alloc(), Java_csql_jdbc_JSqlStatement_close(), Java_csql_jdbc_JSqlStatement_execute(), Java_csql_jdbc_JSqlStatement_free(), Java_csql_jdbc_JSqlStatement_freeStmt(), Java_csql_jdbc_JSqlStatement_next(), Java_csql_jdbc_JSqlStatement_setByte(), Java_csql_jdbc_JSqlStatement_setConnectionPtr(), Java_csql_jdbc_JSqlStatement_setDate(), Java_csql_jdbc_JSqlStatement_setDouble(), Java_csql_jdbc_JSqlStatement_setFloat(), Java_csql_jdbc_JSqlStatement_setInt(), Java_csql_jdbc_JSqlStatement_setLong(), Java_csql_jdbc_JSqlStatement_setShort(), Java_csql_jdbc_JSqlStatement_setString(), Java_csql_jdbc_JSqlStatement_setTime(), Java_csql_jdbc_JSqlStatement_setTimestamp(), main(), SqlGwStatement::prepare(), remove(), SqlGwStatement::setAdapter(), AbsSqlStatement::setInnerStatement(), PacketExecute::unmarshall(), verifyCount(), and verifyPrimKeyFldVal().

STMT_TYPE stmtType = SELECT

Definition at line 28 of file isql.cxx.

Referenced by getInput(), and setStmtType().

---