sdbDataSourceComm.hpp

Go to the documentation of this file.

/*******************************************************************************


   Copyright (C) 2011-2018 SequoiaDB Ltd.

   Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.

   Source File Name = sdbDataSourceComm.hpp

   Descriptive Name = SDB Data Source Common Include Header

   When/how to use: this program may be used on sequoiadb data source function.

   Dependencies: N/A

   Restrictions: N/A

   Change Activity:
   defect Date        Who Description
   ====== =========== === ==============================================
         06/30/2016   LXJ Initial Draft

   Last Changed =

*******************************************************************************/

#ifndef SDB_DATA_SOURCE_COMM_HPP_
#define SDB_DATA_SOURCE_COMM_HPP_

#include "ossTypes.h"
#include <string>
#include "client.hpp"

using std::string;
namespace sdbclient
{
   #define SDB_DS_TOPRECREATE_THRESHOLD                2

   #define SDB_DS_CHECKUNNORMALCOORD_INTERVAL          (60 * 1000)

   #define SDB_DS_CREATECONN_RETRYTIME                 3

   enum DATASOURCE_STRATEGY
   {
      DS_STY_SERIAL,             
      DS_STY_RANDOM,             
      DS_STY_LOCAL,              
      DS_STY_BALANCE             
   } ;

   class DLLEXPORT sdbDataSourceConf
   {
   public:
      sdbDataSourceConf()
         :_userName(),
         _passwd(),
         _initConnCount(10),
         _deltaIncCount(10),
         _maxIdleCount(20),
         _maxCount(500),
         _checkInterval(60 * 1000),
         _keepAliveTimeout(0 * 1000),
         _syncCoordInterval(0 * 1000),
         _validateConnection(FALSE),
         _connectStrategy(DS_STY_BALANCE),
         _useSSL(FALSE) {}

   private:
      // user info
      string               _userName ;
      string               _passwd ;
      // connection number info
      INT32                _initConnCount ;
      INT32                _deltaIncCount ;
      INT32                _maxIdleCount ;
      INT32                _maxCount ;
      // check idle connection interval
      INT32                _checkInterval ;
      INT32                _keepAliveTimeout ;
      // sync coord interval
      INT32                _syncCoordInterval ;
      // whether check validation when a connection out
      BOOLEAN              _validateConnection ;
      // strategy to create connections
      DATASOURCE_STRATEGY  _connectStrategy ;

      // if configure is valid
      BOOLEAN              _useSSL ;

   public:
      void setUserInfo( 
         const string &username, 
         const string &passwd ) ;
      string getUserName() const { return _userName ; }
      string getPasswd() const { return _passwd ; }

      void setConnCntInfo( 
         INT32 initCnt,
         INT32 deltaIncCnt,
         INT32 maxIdleCnt,
         INT32 maxCnt ) ;
      
      INT32 getInitConnCount() const { return _initConnCount ; }
      
      INT32 getDeltaIncCount() const { return _deltaIncCount ; }
      
      INT32 getMaxIdleCount() const { return _maxIdleCount ; }
      
      INT32 getMaxCount() const { return _maxCount ; }

      void setCheckIntervalInfo( INT32 interval, INT32 aliveTime = 0 ) ;
      
      INT32 getCheckInterval() const { return _checkInterval ; }
      
      INT32 getKeepAliveTimeout() const { return _keepAliveTimeout ; }
     
      void setSyncCoordInterval ( INT32 interval ) 
      {
         _syncCoordInterval = interval ; 
      }
      INT32 getSyncCoordInterval() const { return _syncCoordInterval ; }

      void setValidateConnection( BOOLEAN bCheck ) 
      {
         _validateConnection = bCheck ; 
      }
      
      BOOLEAN getValidateConnection() const { return _validateConnection ; }

      void setConnectStrategy( DATASOURCE_STRATEGY strategy )
      {
         _connectStrategy = strategy ;
      }
      DATASOURCE_STRATEGY getConnectStrategy() const 
      {
         return _connectStrategy ; 
      }

      void setUseSSL( BOOLEAN useSSL )
      {
         _useSSL = useSSL ;
      }
      BOOLEAN getUseSSL() const { return _useSSL ; }
      

      BOOLEAN isValid() ;
      
   } ;
}
#endif