pans

2017-01-04 7bcd2613bb116eff33d6e2358bd8c737bacc3cc1

 RtspFace/demo/src/db/DBuntil.cpp

@@ -1,27 +1,35 @@
#include "DBuntil.h"

#include <mysql.h>

#include <cstdio>

#include <iostream>



const char DBuntil::user[] = "root";         
const char DBuntil::pswd[] = "";        
const char DBuntil::host[] = "localhost";    
const char DBuntil::db[] = "demo";       
unsigned int DBuntil::port = 3306; 


MYSQL myCont;

MYSQL_RES *result;

MYSQL_ROW sql_row;

#pragma comment(lib,"D:\\Program Files\\mysql-5.7.17-winx64\\lib\\libmysql.lib") 


DBuntil::DBuntil()

DBuntil::DBuntil(){}



DBuntil::DBuntil(my_db mydb)

{

   mysql_init(&myCont);

   mysql_real_connect(&myCont, host, user, pswd, db, port, NULL, 0);

   if(mysql_init(&myCont)!=NULL)

   {

      std::cout<<"init succeed"<<std::endl;

   }

   else

      std::cout<<"init failed"<<std::endl;



   if(mysql_real_connect(&myCont, mydb.host, mydb.user, mydb.pswd, mydb.db, mydb.port, NULL, 0) != NULL)

   {

      std::cout<<"mysql_real_connect succeed"<<std::endl;

   }

   else

      std::cout<<"mysql_real_connect failed"<<std::endl;

}



DBuntil::~DBuntil()

{

   if (result != NULL) 
   if (result != NULL)

      mysql_free_result(result);



   mysql_close(&myCont);

@@ -29,28 +37,27 @@


person DBuntil::db_rearch(int f_id)

{

   person p={0,""};

   person p= {0,""};

   db_select(f_id,&p);

   //对结构体赋值

   //对结构体赋值

   return p;

}



int DBuntil::db_select(int f_id,person* per)

bool DBuntil::db_select(int f_id,person* per)

{

   //sql="select a.p_id,b.`name`,b.img from face_person a,user_info b where a.face_id = " + f_id + " AND a.p_id = b.pid ";

   char c_sql[1024];

   sprintf( c_sql, "select a.p_id,b.`name`,b.img from face_person a,user_info b where a.face_id = %d AND a.p_id = b.pid " , f_id ); 
	
   //sprintf( sql, "select a.p_id,b.`name`,b.img from face_person a,user_info b where a.face_id = %d AND a.p_id = b.pid " , f_id ); 
   mysql_query(&myCont, "SET NAMES gbk"); //设置编码格式

   res = mysql_query(&myCont,c_sql);//查询



   sprintf( sql, "select a.p_id,b.`name`,b.img from face_person a,user_info b where a.face_id = %d AND a.p_id = b.pid " , f_id );



   mysql_query(&myCont, "SET NAMES utf8"); //设置编码格式

   res = mysql_query(&myCont,sql);//查询

   if (!res)

   {

      result = mysql_store_result(&myCont);

      if (result)

      {

         while (sql_row = mysql_fetch_row(result))//获取具体的数据

         while (sql_row = mysql_fetch_row(result))

         {

            //获取具体的数据

            per->p_id = atoi( sql_row[0]);

            per->name = sql_row[1];

         }

@@ -58,7 +65,33 @@
   }

   else

   {

      //cout << "query sql failed!" << endl;

      std::cout<<"query sql failed!"<<std::endl;

      return false;

   }

   return per->p_id;

   return true;

}



bool DBuntil::db_add(int f_id,person *per)

{

   //

   sprintf( sql, "INSERT INTO user_info(NAME, img) VALUES('%s', NULL)" , per->name );

   res = mysql_query(&myCont,sql);

   if(!res)

   {

      sprintf( sql, "INSERT INTO face_person(p_id, face_id) VALUES (LAST_INSERT_ID(), %d)" , f_id );

      res = mysql_query(&myCont,sql);

      if(!res)

      {

         return true;

      }

   }

   return false;

}



bool DBuntil::db_register(int f_id,person *per)

{

   if(db_add(f_id,per)){

      return true;

   }

   return false;

}