Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
vagetablechicken committed Jun 26, 2023
1 parent 3e9c576 commit 443d0fe
Showing 1 changed file with 51 additions and 51 deletions.
102 changes: 51 additions & 51 deletions src/sdk/openmldb_api.h
Original file line number Diff line number Diff line change
Expand Up @@ -85,57 +85,6 @@ class OpenmldbNull {
OpenmldbNull() {}
};

// OpenmldbHandler is used to link openmldb server. to use openmldb, you must create an object of this type
// cluster :
// constructor : first parameter string format : "IP:Port" eg : "127.0.0.1:2181"
// second parameter string format : "path" eg : "/openmldb"
// standalone :
// constructor : first parameter string format : "IP" eg : "127.0.0.1"
// second parameter string format : "Port" eg : 6527
class OpenmldbHandler {
public:
OpenmldbHandler(std::string zk_cluster, std::string zk_path);
OpenmldbHandler(std::string host, uint32_t _port);
OpenmldbHandler(openmldb::sdk::SQLClusterRouter* router) { router_ = router; }
~OpenmldbHandler();
openmldb::sdk::SQLClusterRouter* get_router() const { return router_; }

// execute() is used to execute SQL statements without parameters
// first parameter : OpenmldbHandler
// second parameter : string pass SQL statement
bool execute(const std::string& sql);

// execute() is used to execute SQL statements without parameters
// first parameter : OpenmldbHandler a object of type OpenmldbHandler
// second parameter : string name of database
// third parameter : string SQL statement
bool execute(const std::string& db, const std::string& sql);

// execute_parameterized() is used to execute SQL statements with parameters
// first parameter : OpenmldbHandler a object of type OpenmldbHandler
// second parameter : string name of database
// third parameter : string SQL statement
// forth parameter : ParameterRow a object of type ParameterRow
bool execute_parameterized(const std::string& db, const std::string& sql, const ParameterRow& para);

// execute_request() is used to execute SQL of request mode
// only one parameter, a object of type RequestRow
bool execute_request(const RequestRow& req);

// get the results of the latest SQL query
std::shared_ptr<hybridse::sdk::ResultSet> get_resultset() { return resultset_last_; }
hybridse::sdk::Status* get_status() const { return status_; }

private:
OpenmldbHandler(const OpenmldbHandler&);
OpenmldbHandler& operator=(const OpenmldbHandler&);

private:
hybridse::sdk::Status* status_ = new hybridse::sdk::Status();
openmldb::sdk::SQLClusterRouter* router_ = nullptr;
std::shared_ptr<hybridse::sdk::ResultSet> resultset_last_;
};

// In the request with parameter and request mode of openmldb, the position of parameters to be filled is indicated by
// the symbol "?" to express

Expand Down Expand Up @@ -204,6 +153,57 @@ class RequestRow {
uint32_t str_length_ = 0;
};

// OpenmldbHandler is used to link openmldb server. to use openmldb, you must create an object of this type
// cluster :
// constructor : first parameter string format : "IP:Port" eg : "127.0.0.1:2181"
// second parameter string format : "path" eg : "/openmldb"
// standalone :
// constructor : first parameter string format : "IP" eg : "127.0.0.1"
// second parameter string format : "Port" eg : 6527
class OpenmldbHandler {
public:
OpenmldbHandler(std::string zk_cluster, std::string zk_path);
OpenmldbHandler(std::string host, uint32_t _port);
OpenmldbHandler(openmldb::sdk::SQLClusterRouter* router) { router_ = router; }
~OpenmldbHandler();
openmldb::sdk::SQLClusterRouter* get_router() const { return router_; }

// execute() is used to execute SQL statements without parameters
// first parameter : OpenmldbHandler
// second parameter : string pass SQL statement
bool execute(const std::string& sql);

// execute() is used to execute SQL statements without parameters
// first parameter : OpenmldbHandler a object of type OpenmldbHandler
// second parameter : string name of database
// third parameter : string SQL statement
bool execute(const std::string& db, const std::string& sql);

// execute_parameterized() is used to execute SQL statements with parameters
// first parameter : OpenmldbHandler a object of type OpenmldbHandler
// second parameter : string name of database
// third parameter : string SQL statement
// forth parameter : ParameterRow a object of type ParameterRow
bool execute_parameterized(const std::string& db, const std::string& sql, const ParameterRow& para);

// execute_request() is used to execute SQL of request mode
// only one parameter, a object of type RequestRow
bool execute_request(const RequestRow& req);

// get the results of the latest SQL query
std::shared_ptr<hybridse::sdk::ResultSet> get_resultset() { return resultset_last_; }
hybridse::sdk::Status* get_status() const { return status_; }

private:
OpenmldbHandler(const OpenmldbHandler&);
OpenmldbHandler& operator=(const OpenmldbHandler&);

private:
hybridse::sdk::Status* status_ = new hybridse::sdk::Status();
openmldb::sdk::SQLClusterRouter* router_ = nullptr;
std::shared_ptr<hybridse::sdk::ResultSet> resultset_last_;
};

// print_resultset() is used to print the results of SQL query
// only one parameter, a object of type shared_ptr<hybridse::sdk::ResultSet>
void print_resultset(std::shared_ptr<hybridse::sdk::ResultSet> rs);
Expand Down

0 comments on commit 443d0fe

Please sign in to comment.