src/sql/SqlFactory.cxx

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by Prabakaran Thirumalai   *
   3  *   praba_tuty@yahoo.com   *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15   ***************************************************************************/
  16 #include <SqlFactory.h>
  17 #include <SqlStatement.h>
  18 #include <SqlConnection.h>
  19 #include <SqlLogConnection.h>
  20 #include <SqlLogStatement.h>
  21 #include <SqlOdbcConnection.h>
  22 #include <SqlOdbcStatement.h>
  23 #include <SqlGwStatement.h>
  24 #include <SqlNwConnection.h>
  25 #include <SqlNwStatement.h>
  26
  27 Config Conf::config;
  28
  29 AbsSqlConnection* SqlFactory::createConnection(SqlApiImplType implFlag)
  30 {
  31     AbsSqlConnection *conn = NULL ;
  32     Conf::config.readAllValues(os::getenv("CSQL_CONFIG_FILE"));
  33     bool isSqlLogNeeded = ( Conf::config.useDurability() ||
  34                           ( Conf::config.useCache() &&
  35                             Conf::config.getCacheMode() == ASYNC_MODE) );
  36     switch(implFlag)
  37     {
  38         case CSql:
  39             if (!Conf::config.useDurability()) {
  40                 conn = new SqlConnection();
  41             }else {
  42                AbsSqlConnection *sqlCon = new SqlConnection();
  43                conn = new SqlLogConnection();
  44                SqlLogConnection *logCon = (SqlLogConnection *)conn;
  45                logCon->setNoMsgLog(true);
  46                conn->setInnerConnection(sqlCon);
  47             }
  48             break;
  49         case CSqlLog:
  50             {
  51             //generates sql logs
  52             AbsSqlConnection *sqlCon = new SqlConnection();
  53             conn = new SqlLogConnection();
  54             conn->setInnerConnection(sqlCon);
  55             break;
  56             }
  57 #ifndef MMDB
  58         case CSqlAdapter:
  59             {
  60             conn = new SqlOdbcConnection();
  61             conn->setInnerConnection(NULL);
  62             break;
  63             }
  64         case CSqlGateway:
  65             {
  66             AbsSqlConnection *sqlCon = new SqlConnection();
  67             SqlGwConnection *gwconn = new SqlGwConnection();
  68             if (isSqlLogNeeded) {
  69                 AbsSqlConnection *sqllogconn = new SqlLogConnection();
  70                 sqllogconn->setInnerConnection(sqlCon);
  71                 gwconn->setInnerConnection(sqllogconn);
  72             } else gwconn->setInnerConnection(sqlCon);
  73
  74             //createAdapters for MultiDSN
  75             gwconn->createAdapters(gwconn);
  76             conn = gwconn;
  77             break;
  78             }
  79 #endif
  80         case CSqlNetwork:
  81             {
  82             SqlNwConnection *sqlNwCon = new SqlNwConnection(CSqlNetwork);
  83             sqlNwCon->setInnerConnection(NULL);
  84             conn = sqlNwCon;
  85             break;
  86             }
  87         case CSqlNetworkAdapter:
  88             {
  89             SqlNwConnection *sqlNwCon = new SqlNwConnection(CSqlNetworkAdapter);
  90             sqlNwCon->setInnerConnection(NULL);
  91             conn = sqlNwCon;
  92             break;
  93             }
  94         case CSqlNetworkGateway:
  95             {
  96             SqlNwConnection *sqlNwCon = new SqlNwConnection(CSqlNetworkGateway);
  97             sqlNwCon->setInnerConnection(NULL);
  98             conn = sqlNwCon;
  99             break;
 100             }
 101         case CSqlDirect:
 102             conn = new SqlConnection();
 103             break;
 104         default:
 105             printf("Todo");
 106             break;
 107     }
 108     return conn;
 109 }
 110
 111 AbsSqlStatement* SqlFactory::createStatement(SqlApiImplType implFlag)
 112 {
 113     AbsSqlStatement *stmt = NULL;
 114     bool isSqlLogNeeded = ( Conf::config.useDurability() ||
 115                           ( Conf::config.useCache() &&
 116                             Conf::config.getCacheMode() == ASYNC_MODE ));
 117     switch(implFlag)
 118     {
 119         case CSql:
 120             if (!Conf::config.useDurability()) {
 121                 stmt = new SqlStatement();
 122             }else {
 123                AbsSqlStatement *sqlStmt = new SqlStatement();
 124                stmt = new SqlLogStatement();
 125                stmt->setInnerStatement(sqlStmt);
 126             }
 127             break;
 128         case CSqlLog:
 129             {
 130             //generates sql logs
 131             AbsSqlStatement *sqlStmt = new SqlStatement();
 132             stmt = new SqlLogStatement();
 133             stmt->setInnerStatement(sqlStmt);
 134             break;
 135             }
 136 #ifndef MMDB
 137         case CSqlAdapter:
 138             {
 139             stmt = new SqlOdbcStatement();
 140             stmt->setInnerStatement(NULL);
 141             break;
 142             }
 143         case CSqlGateway:
 144             {
 145             SqlGwStatement *gwstmt = new SqlGwStatement();
 146             AbsSqlStatement *sqlstmt = new SqlStatement();
 147
 148             if (isSqlLogNeeded) {
 149                 AbsSqlStatement *sqllogstmt = new SqlLogStatement();
 150                 sqllogstmt->setInnerStatement(sqlstmt);
 151                 gwstmt->setInnerStatement(sqllogstmt);
 152             } else gwstmt->setInnerStatement(sqlstmt);
 153             AbsSqlStatement *adapterstmt = new SqlOdbcStatement();
 154             gwstmt->setAdapter(adapterstmt);
 155             stmt = gwstmt;
 156             break;
 157             }
 158 #endif
 159         case CSqlNetwork:
 160             {
 161             SqlNwStatement *sqlNwStmt = new SqlNwStatement();
 162             sqlNwStmt->setInnerStatement(NULL);
 163             stmt = sqlNwStmt;
 164             break;
 165             }
 166         case CSqlNetworkAdapter:
 167             {
 168             SqlNwStatement *sqlNwStmt = new SqlNwStatement();
 169             sqlNwStmt->setInnerStatement(NULL);
 170             stmt=sqlNwStmt;
 171             break;
 172             }
 173         case CSqlNetworkGateway:
 174             {
 175             SqlNwStatement *sqlNwStmt = new SqlNwStatement();
 176             sqlNwStmt->setInnerStatement(NULL);
 177             stmt = sqlNwStmt;
 178             break;
 179             }
 180         case CSqlDirect:
 181             stmt = new SqlStatement();
 182             break;
 183         default:
 184             printf("Todo");
 185             break;
 186     }
 187     return stmt;
 188 }