src/com/xquery/xqueryClientLayer.h

/*********************************************************************
* Copyright (c) 2017 fortiss GmbH
*
* This program and the accompanying materials are made
* available under the terms of the Eclipse Public License 2.0
* which is available at https://www.eclipse.org/legal/epl-2.0/
*
* SPDX-License-Identifier: EPL-2.0
**********************************************************************/

#ifndef SRC_MODULES_XQUERY_XQUERYCLIENT_H_
#define SRC_MODULES_XQUERY_XQUERYCLIENT_H_

#include <comlayer.h>
#include <extevhan.h>

using namespace forte::com_infra;

class CXqueryClientLayer : public forte::com_infra::CComLayer{
  public:
    CXqueryClientLayer(forte::com_infra::CComLayer* paUpperLayer, forte::com_infra::CBaseCommFB* paComFB);
    ~CXqueryClientLayer() override;

    EComResponse sendData(void *paData, unsigned int paSize) override;
    EComResponse recvData(const void *paData, unsigned int paSize) override;
    EComResponse processInterrupt() override;

    const char * getCommand(){
      return command;
    }
    int getSfd(){
      return sfd;
    }

  private:
    void closeConnection() override;
    EComResponse openConnection(char *paLayerParameter) override;
    bool parseParameters(char *paLayerParameter);
    void openDB();

    int sfd;
    char *host;
    char *port;
    char *dbName;
    char *usr;
    char *psw;
    static const char *scmParameterSeperator;
    char *command;
};

#endif /* SRC_MODULES_XQUERY_XQUERYCLIENT_H_ */