| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596 |
- <%!-lmysqlclient%><%@ class mypage %><%#
- #include <mysql/mysql.h>
- #include <json/json.h>
- #include <cpoll/threadpool.H>
- #include <list>
- #include "connectioninfo.H"
- #include "generic_pool.H"
- using namespace CP;
- using namespace cppsp;
- using namespace std;
- bool comp_string(const String& x, const String& y) {
- if (x.len == 0 || y.len == 0) return x.len < y.len;
- int complen = x.len < y.len ? x.len : y.len;
- int tmp = memcmp(x.d, y.d, complen);
- if (tmp == 0) return x.len < y.len;
- else return tmp < 0;
- }
- struct fortune
- {
- String message;
- int id;
- bool operator<(const fortune& other) const {
- return comp_string(message,other.message);
- }
- };
- genericPool<MYSQL*,64> sqlPool(&doConnect,&doDisconnect);
- ThreadPool tp(16);
- void do_init_thread(void*) {
- mysql_thread_init();
- }
- void do_deinit_thread(void*) {
- mysql_thread_end();
- }
- extern "C" void initModule() {
- mysql_library_init(0,NULL,NULL);
- tp.afterStart=&do_init_thread;
- tp.beforeExit=&do_deinit_thread;
- }
- %><%$
- EventFD efd{0,EFD_SEMAPHORE};
- vector<fortune> fortunes;
- MYSQL* db;
- //function to be executed in the thread pool
- void tpFunc() {
- mysql_query(db, "SELECT id, message FROM Fortune;");
- MYSQL_RES *sqlres = mysql_store_result(db);
- if (sqlres==NULL) throw runtime_error(mysql_error(db));
- MYSQL_ROW row;
- while( (row=mysql_fetch_row(sqlres)) ){
- fortunes.push_back({sp->addString(row[1]),atoi(row[0])});
- }
- mysql_free_result(sqlres);
- fortunes.push_back({"Additional fortune added at request time.",0});
- sort(fortunes.begin(),fortunes.end());
- efd.sendEvent(1);
- }
- //asynchronously load the data in the doInit() function, and defer page rendering until data is available
- void doInit() override {
- response->headers["Server"]="cppsp/0.2";
-
- db=sqlPool.get();
- poll->add(efd);
- tp.invoke({&mypage::tpFunc,this});
- efd.getEvent({&mypage::efdCB,this});
- }
- void efdCB(eventfd_t efdVal) {
- sqlPool.put(db);
- Page::doInit();
- }
- %>
- <!DOCTYPE html>
- <html>
- <head><title>Fortunes</title></head>
- <body>
- <table>
- <tr><th>id</th><th>message</th></tr>
- <%
- for(int i=0;i<fortunes.size();i++) {
- %>
- <tr><td><%=fortunes[i].id%></td><td><%htmlEscape(fortunes[i].message,output);%></td></tr><%
- }
- %>
- </table>
- </body>
- </html>
|
