opt：connect_db增加charset设置字符集类型

extern/ExternFunctionHandler.cpp

@@ -292,7 +292,10 @@ Function *ExternFunctionHandler::getOrAddConnectDB(LLVMContext &context, Module
                                                                              context)->getPointerTo(),
                                                                      Type::getInt8Ty(
                                                                              context)->getPointerTo(),
-                                                                     Type::getInt32Ty(context)
+                                                                     Type::getInt32Ty(
+                                                                             context),
+                                                                     Type::getInt8Ty(
+                                                                             context)->getPointerTo()
                                          },
                                          false);
     func = Function::Create(ty, llvm::GlobalValue::ExternalLinkage, "_ksql_connect_db", module);

module/sql/src/ksql.cpp

@@ -6,15 +6,14 @@
 
 mysql::MySQL_Driver *driver;
 Connection *conn;
-//Statement *statement;
-//ResultSet *resultSet;
 WEBC_SQL_DATA webcSqlData;
 unique_ptr<char[]> ch;
 vector<string> ans;
 
 string _ksql_resToJson(WEBC_SQL_DATA sqlData);
 
-int _ksql_connect_db(const char *hostname, const char *username, const char *password, const char *schema, int port) {
+int _ksql_connect_db(const char *hostname, const char *username, const char *password, const char *schema, int port,
+                     const char *charset) {
     try {
         driver = mysql::get_mysql_driver_instance();
         //连接到Mysql
@@ -25,14 +24,15 @@ int _ksql_connect_db(const char *hostname, const char *username, const char *pas
         connection_properties["schema"] = schema;
         connection_properties["port"] = port;
         connection_properties["OPT_RECONNECT"] = true;
+        connection_properties["OPT_CHARSET_NAME"] = charset;
         conn = driver->connect(connection_properties);
         if (!conn) {
             cout << "连接Mysql失败" << endl;
             return FAILED;
         }
         return SUCCESS;
     } catch (SQLException e) {
-        cout << e.getErrorCode() << endl;
+        cout << "The error code is : "<<e.getErrorCode() << endl;
         cout << e.what() << endl;
     }
 }
@@ -45,10 +45,8 @@ const char *_ksql_query_db(const char *sqlSentence) {
         _ksql_free_memory();
         string temp = sqlSentence;
         replace(temp.begin(), temp.end(), '\"', '\'');
-//        statement = conn->createStatement();
         webcSqlData.statement = conn->createStatement();
         sqlSentence = temp.c_str();
-//        resultSet = statement->executeQuery(sqlSentence);
         webcSqlData.resultSet = webcSqlData.statement->executeQuery(sqlSentence);
         if (!webcSqlData.resultSet->next()) {
             char *resNull = "您所查询的表为空\n";
@@ -60,7 +58,7 @@ const char *_ksql_query_db(const char *sqlSentence) {
         strcpy(ch.get(), _ksql_resToJson(webcSqlData).data());
         return ch.get();
     } catch (SQLException e) {
-        cout << e.getErrorCode() << endl;
+        cout << "The error code is : "<<e.getErrorCode() << endl;
         cout << e.what() << endl;
     }
 }
@@ -72,7 +70,6 @@ string _ksql_resToJson(WEBC_SQL_DATA sqlData) {
         s += "\"result\":";
         s += "[";
         //列数
-//        int count = result->getMetaData()->getColumnCount();
         int count = sqlData.resultSet->getMetaData()->getColumnCount();
         if (ans.empty()) {
             sqlData.resultSet->beforeFirst();
@@ -108,7 +105,7 @@ string _ksql_resToJson(WEBC_SQL_DATA sqlData) {
         vector<string>().swap(ans);
         return s;
     } catch (SQLException e) {
-        cout << e.getErrorCode() << endl;
+        cout << "The error code is : "<<e.getErrorCode() << endl;
         cout << e.what() << endl;
     }
 }

module/sql/src/ksql.h

@@ -23,6 +23,7 @@
 //操作成功状态码
 #define SUCCESS 0
 
+
 using namespace sql;
 using namespace std;
 
@@ -35,23 +36,24 @@ typedef SQLData WEBC_SQL_DATA;
 
 extern "C" {
 /**
- * 连接到mysql
+ * 连接到MySQL
  * @param hostname
  * @param username
  * @param password
  * @param schema
- * @param port
+ * @param port 端口
+ * @param charset 字符集
  * @return
  */
-int _ksql_connect_db(const char *hostname, const char *username, const char *password, const char *schema, int port);
+int _ksql_connect_db(const char *hostname, const char *username, const char *password, const char *schema, int port,const char *charset);
 /**
- * 释放资源
+ * 释放内存
  * @return
  */
 int _ksql_free_memory();
 /**
  * 查询数据
- * @param sqlSentence
+ * @param sqlSentence select语句
  * @return
  */
 const char *_ksql_query_db(const char *sqlSentence);

module/sql/src/ksqldemo.cpp

@@ -5,7 +5,7 @@
 #include "ksql.h"
 
 int main() {
-    _ksql_connect_db("127.0.0.1", "root", "123456", "school", 3306);
+    _ksql_connect_db("127.0.0.1", "root", "123456", "school", 3306,"GBK");
 //    auto a = strToJson(_ksql_query_db("select * from subject"));
 //    cout<<jsonToStr(a);
     cout << _ksql_query_db("select * from subject");

test/test.c

@@ -15,7 +15,7 @@ str hehe() {
 
 int main() {
     echo('init...');
-    connect_db('127.0.0.1', 'root', '123456', 'school',3306);
+    connect_db('127.0.0.1', 'root', '123456', 'school',3306,'utf8');
     str host = '0.0.0.0';
     int port = 9000;
     int core = 2;