From c56015c5c73861b5f794cac48064d0394f8fd37d Mon Sep 17 00:00:00 2001
From: pansen <pansen626@sina.com>
Date: 星期二, 02 四月 2019 15:48:39 +0800
Subject: [PATCH] 对抓拍记录的picMaxUrl字段赋值(大图路径)

---
 QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h |   35 +++++++++++++++++++++--------------
 1 files changed, 21 insertions(+), 14 deletions(-)

diff --git a/QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h b/QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h
index 1852583..bfffec3 100644
--- a/QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h
+++ b/QiaoJiaSystem/DataManagerServer/vss/dao/BaseDao.h
@@ -8,11 +8,15 @@
 #include <iostream>
 #include <mysql++.h>
 #include <AppConfig.h>
+#include <QtCore/QMutex>
 
 using namespace std;
 
-static mysqlpp::Connection* conn;
 class BaseDao {
+public:
+    static QMutex m_mutexVisit;
+private:
+    static mysqlpp::Connection* conn;
 public:
     static mysqlpp::SimpleResult add(std::map<std::string, std::string>& columns, string tableName) {
         initConnection();
@@ -73,7 +77,8 @@
         return rowDataList;
     }
 
-    static Json::Value findJsonArray(string sql) {
+    static Json::Value findJsonArray(string sql, std::map<std::string, std::string>& whereColumns) {
+        sql = sql + getWhereColumnNameValuePair(whereColumns);
         initConnection();
         mysqlpp::Query query = conn->query(sql);
         Json::Value rowList;
@@ -93,6 +98,7 @@
                 rowList.append(row);
             }
         } else {
+            cout << "error " <<query.error() << endl;
             cout << "query failed" << endl;
         }
         return rowList;
@@ -126,20 +132,21 @@
         return updateSql;
     }
     static void doConnect() {
-        //            if (conn->connect(
-//                    appConfig.getStringProperty("database").c_str(),
-//                    appConfig.getStringProperty("db_host").c_str(),
-//                    appConfig.getStringProperty("db_user").c_str(),
-//                    appConfig.getStringProperty("db_password").c_str(),
-//                    appConfig.getIntProperty("db_port")
-//            )) {
+        cout << "db_host=" << appConfig.getStringProperty("db_host").c_str() << endl;
         if (conn->connect(
-                "basic_business_table",
-                "127.0.0.1",
-                "root",
-                "root",
-                3306
+            appConfig.getStringProperty("database").c_str(),
+            appConfig.getStringProperty("db_host").c_str(),
+            appConfig.getStringProperty("db_user").c_str(),
+            appConfig.getStringProperty("db_password").c_str(),
+            appConfig.getIntProperty("db_port")
         )) {
+//        if (conn->connect(
+//                "EGEyesForVSS",
+//                "192.168.1.148",
+//                "root",
+//                "123456",
+//                3306
+//        )) {
             cout << "connect success" << endl;
         } else {
             cout << "connect failed" << endl;

--
Gitblit v1.8.0