modify mysql select error!

src/impl/AuthenticationSubscriptionDocumentApiImpl.cpp

@@ -17,6 +17,12 @@
 
 #include <AuthenticationSubscription.h>
 
+#include "udr_config.hpp"
+
+using namespace config;
+
+extern udr_config udr_cfg;
+
 namespace org {
 namespace openapitools {
 namespace server {
@@ -37,6 +43,14 @@ void AuthenticationSubscriptionDocumentApiImpl::
         const Pistache::Optional<std::string> &supportedFeatures,
         Pistache::Http::ResponseWriter &response) {
 
+  MYSQL mysqldb;
+  mysql_init(&mysqldb);
+  if (!mysql_real_connect(&mysqldb, udr_cfg.mysql.mysql_server.c_str(),udr_cfg.mysql.mysql_user.c_str(),udr_cfg.mysql.mysql_pass.c_str(),udr_cfg.mysql.mysql_db.c_str(), udr_cfg.mysql.mysql_port, 0, 0)) 
+  {
+    Logger::udr_server().error("An error occurred while connecting to db: %s", mysql_error(&mysqldb));
+    return ;
+  }
+
   MYSQL_RES *res = NULL;
   MYSQL_ROW row;
 
@@ -54,14 +68,14 @@ void AuthenticationSubscriptionDocumentApiImpl::
           .get_to(sequencenumber);
 
       if (mysql_real_query(
-              mysql_WitcommUDRDB, select_Authenticationsubscription.c_str(),
+              &mysqldb, select_Authenticationsubscription.c_str(),
               (unsigned long)select_Authenticationsubscription.size())) {
         Logger::udr_server().error("mysql_real_query failure！SQL(%s)",
                                    select_Authenticationsubscription.c_str());
         return;
       }
 
-      res = mysql_store_result(mysql_WitcommUDRDB);
+      res = mysql_store_result(&mysqldb);
       if (res == NULL) {
         Logger::udr_server().error("mysql_store_result failure！SQL(%s)",
                                    select_Authenticationsubscription.c_str());
@@ -84,7 +98,7 @@ void AuthenticationSubscriptionDocumentApiImpl::
 
       //            Logger::udr_server().debug("modify content:
       //            %s",query.c_str());
-      if (mysql_real_query(mysql_WitcommUDRDB, query.c_str(),
+      if (mysql_real_query(&mysqldb, query.c_str(),
                            (unsigned long)query.size())) {
         Logger::udr_server().error("update mysql failure！SQL(%s)",
                                    query.c_str());
@@ -114,18 +128,26 @@ void AuthenticationSubscriptionDocumentApiImpl::
 
   nlohmann::json j;
 
+  MYSQL mysqldb;
+  mysql_init(&mysqldb);
+  if (!mysql_real_connect(&mysqldb, udr_cfg.mysql.mysql_server.c_str(),udr_cfg.mysql.mysql_user.c_str(),udr_cfg.mysql.mysql_pass.c_str(),udr_cfg.mysql.mysql_db.c_str(), udr_cfg.mysql.mysql_port, 0, 0)) 
+  {
+    Logger::udr_server().error("An error occurred while connecting to db: %s", mysql_error(&mysqldb));
+    return ;
+  }
+
   AuthenticationSubscription authenticationsubscription;
   const std::string query =
       "select * from AuthenticationSubscription WHERE ueid='" + ueId + "'";
 
-  if (mysql_real_query(mysql_WitcommUDRDB, query.c_str(),
+  if (mysql_real_query(&mysqldb, query.c_str(),
                        (unsigned long)query.size())) {
     Logger::udr_server().error("mysql_real_query failure！SQL(%s)",
                                query.c_str());
     return;
   }
 
-  res = mysql_store_result(mysql_WitcommUDRDB);
+  res = mysql_store_result(&mysqldb);
   if (res == NULL) {
     Logger::udr_server().error("mysql_store_result failure！SQL(%s)",
                                query.c_str());