commit

extern/ExternFunctionHandler.cpp

@@ -310,7 +310,7 @@ Function *ExternFunctionHandler::getOrAddQueryDB(LLVMContext &context, Module &m
     if (func != NIL) {
         return func;
     }
-    FunctionType *ty = FunctionType::get(Type::getInt32Ty(context)->getPointerTo(), {Type::getInt8Ty(context)->getPointerTo()},
+    FunctionType *ty = FunctionType::get(Type::getInt32Ty(context), {Type::getInt8Ty(context)->getPointerTo()},
                                          false);
     func = Function::Create(ty, llvm::GlobalValue::ExternalLinkage, "_query_db", module);
     return func;

module/sql/src/ksql.cpp

@@ -34,20 +34,21 @@ int _free_connect() {
 }
 
 int _query_db(const char *sqlSentence) {
-    string temp = sqlSentence;
+    const char *my = "select * from student";
+//    string temp = sqlSentence;
+    string temp = my;
     replace(temp.begin(),temp.end(),'\"','\'');
     statement = conn->createStatement();
 //    statement->executeQuery(sqlSentence);
     sqlSentence = temp.c_str();
     resultSet = statement->executeQuery(sqlSentence);
-    if (!resultSet) return FAILED;
 //    _print_json(metaData);
-//    cout<<_resToJson(resultSet);
+    cout<<_resToJson(resultSet);
 //    const char * c = _resToJson(resultSet).c_str();
 //    SYSY_JSON_DATA temp = strToJson(c);
 //    cout<<jsonToStr(temp)<<endl;
-    cout << _resToJson(resultSet) << endl;
-    return SUCCESS;
+//    return _resToJson(resultSet);
+    return 1;
 }
 
 string _resToJson(ResultSet *result) {

module/sql/src/ksql.h

@@ -19,7 +19,7 @@
 #include "vector"
 #include "hash_set"
 //mysql相关参数
-#define HOST "127.0.0.1""
+#define HOST "127.0.0.1"
 #define USER "root"
 #define PASSWD "123456"
 #define DATABASE "test"

module/sql/src/ksqldemo.cpp

@@ -5,6 +5,6 @@
 #include "ksql.h"
 
 int main() {
-    _connect_db("127.0.0.1","root","123456","school");
-    _query_db("select subjectno from subject where subjectname like '高等数学%'");
+    _connect_db("127.0.0.1","root","kcr200123","school");
+    cout<<_query_db("select * from student");
 }

module/web/CMakeLists.txt

@@ -39,9 +39,9 @@ add_executable(webdemo src/webdemo.cpp src/web.hpp src/web.cpp)
 
 add_executable(serverdemo src/serverdemo.cpp src/web.hpp src/web.cpp)
 
-target_link_libraries(webdemo Boost::filesystem Boost::system pthread ${SSLLib_LIBRARIES})
+target_link_libraries(webdemo Boost::filesystem Boost::system pthread ${SSLLib_LIBRARIES} ksql kjson  mysqlcppconn )
 
-target_link_libraries(serverdemo Boost::filesystem Boost::system pthread ${SSLLib_LIBRARIES})
+target_link_libraries(serverdemo Boost::filesystem Boost::system pthread ${SSLLib_LIBRARIES} ksql kjson mysqlcppconn )
 
 install(TARGETS web
         ARCHIVE DESTINATION ${LOCATION}

module/web/src/serverdemo.cpp

@@ -4,8 +4,11 @@
 
 #include "web.hpp"
 
-const char *say_hello() {
-    return "hello_world";
+string ans="";
+const char * say_hello() {
+    _connect_db("127.0.0.1","root","kcr200123","school");
+    ans=_query_db("select * from student");
+    return ans.c_str();
 }
 
 const char *say_hi() {
@@ -15,7 +18,7 @@ const char *say_hi() {
 
 void startServer() {
     int id = _web_getServerId("127.0.0.1",9000,2);
-    _web_addUrlHandler(id, "POST", "/compiler", "text/html", say_hi);
+    _web_addUrlHandler(id, "GET", "/compiler", "text/html", say_hello);
     _web_startServe(id);
 }
 

module/web/src/web.hpp

@@ -7,7 +7,7 @@
 
 #include <map>
 #include <set>
-
+#include "./module/sql/src/ksql.h"
 #include <boost/beast.hpp>
 #include <boost/bind.hpp>
 #include <boost/asio.hpp>

test/test.c

@@ -1,25 +1,31 @@
-//str hi() {
-//    str a = '<h1>hello from kingtous compiler</h1>';
-//    ret a;
-//}
+str hi() {
+    connect_db('127.0.0.1','root','kcr200123','school');
+    int b=query_db('select * from student');
+    str a = '<h1>hello from kingtous compiler</h1>';
+    ret a;
+}
 
-//int main() {
-//    echo('init...');
-//}    echo(hi());
-//    str host = '127.0.0.1';
-//    int port = 9000;
-//    int core = 2;
-//    echo('get server...');
-//    int server_id = getServer(host, port, core);
-//    echo('server id is', server_id);
+int main() {
+    echo('init...');
+    echo(hi());
+    str host = '127.0.0.1';
+    int port = 9000;
+    int core = 2;
+    echo('get server...');
+    int server_id = getServer(host, port, core);
+    echo('server id is', server_id);
+    addUrlHandler(server_id, 'GET', '/compiler', 'text/html', hi);
+    echo('start server in host', host, ',port is', port);
+    startServer(server_id);
+    ret
+    0;
+}
+//int main(){
+//    int server_id=getServer('127.0.0.1', 9000, 2);
 //    addUrlHandler(server_id, 'GET', '/compiler', 'text/html', hi);
-//    echo('start server in host', host, ',port is', port);
-//    startServer(server_id);
-//    ret
-//    0;
-//}
-int main(){
-    connect_db('127.0.0.1','root','123456','school');
-    query_db('select subjectno from subject where subjectname like "高等数学%"');
-    ret 0;
-}
+//    connect_db('127.0.0.1','root','kcr200123",'school');
+//    query_db('select * from student');
+////    int a =12;
+////    echo(a);
+//    ret 0;
+//}