C++连接数据库的实例

xiaoxiao2021-02-28  81

void shujuku(string chepaihao) {     MYSQL * con;      MYSQL_RES *res;     MYSQL_ROW row;     MYSQL * con1;      MYSQL_RES *res1;     MYSQL_ROW row1;     char tmp[400];     char tmp1[400];     char dbuser[30]="root";     //数据库的用户名     char dbpasswd[30]="123456";     //数据库的密码     char dbip[30]="localhost";      //记录数据库服务器名     char dbname[50]="test";         //数据库的名字     char tablename[50]="tingkaoche";     //数据表的名字     char tablename1[50]="suoyouchepai";    //数据表的名字     char *query=NULL;     int rt;     int rt1;     int TT=0;     int TT1=0;     int count = 0;     unsigned int t;     con = mysql_init((MYSQL*) 0);    //数据库初始化     con1 = mysql_init((MYSQL*) 0);      if ( con !=NULL && mysql_real_connect(con,dbip,dbuser,dbpasswd,dbname,3306,NULL,0) )    //连接数据库     {  mysql_real_connect(con1,dbip,dbuser,dbpasswd,dbname,3306,NULL,0);         if (!mysql_select_db(con,dbname))     //选择数据库          {       mysql_select_db(con1,dbname);               con ->reconnect = 1;                 query = "set names \'GBK\'";     //设置数据库编码               rt=mysql_real_query(con,query,strlen(query));      //执行数据库       con1 ->reconnect = 1;                 query = "set names \'GBK\'";               rt1=mysql_real_query(con1,query,strlen(query));          }      }      else      {           MessageBoxA(NULL,"Unable to connect the database,check your configuration!","",NULL);           }         //sprintf(tmp,"update %s set 商品=\'%s\',卖出=%d,成交=%d,涨跌=%d,买进=%d,总量=%d,涨幅=%f,时间=\'%s\' where       %s",tablename,goods,sold,deal,fluctuate,buy,total,delta,time,UpdateCon);     //修改数据库中的数据。 sprintf(tmp,"select * from %s",tablename1);     //查找满足条件的值并输出。 rt=mysql_real_query(con,tmp,strlen(tmp));         res = mysql_store_result(con);//将结果保存在res结构体中         while(row = mysql_fetch_row(res))           {                   //  printf("%s  ",row[0]);  if(row[0]==chepaihao)  {  TT++;  }          }  if(TT>0) {        sprintf(tmp1,"select * from %s",tablename);                rt1=mysql_real_query(con1,tmp1,strlen(tmp1));        res1 = mysql_store_result(con1);        while(row1 = mysql_fetch_row(res1))                  {                                      //     printf("%s  ",row1[0]);   if(row1[0]==chepaihao)   {   TT1++;   }                }   } else {  MessageBoxA(NULL,"你的车牌号不在数据库中,所以不能开门","",NULL);          } if(TT1>0) { MessageBoxA(NULL,"你的车是出去的车","",NULL); } else { // sprintf(tmp,"insert into %s values(%d,%s,%s,%s)",tablename,3,"123344","143423","1343423"); //注意如何向具有自增字段的数据库中插入记录             // rt=mysql_real_query(con,tmp,strlen(tmp)); char aa[20];          strcpy(aa,chepaihao.c_str()); sprintf(tmp,"insert into %s values('%s','%s','%s')",tablename,aa,"12","12"); //注意如何向具有自增字段的数据库插入记录 printf("%s\n",tmp);          rt=mysql_real_query(con,tmp,strlen(tmp)); printf("%d\n",rt);  if (rt)       {            printf("Error making query: %s !!!\n",mysql_error(con));       }       else       {           printf("%s executed!!!\n",tmp);       } system("pause"); }     /* sprintf(tmp,"select * from %s",tablename);      rt=mysql_real_query(con,tmp,strlen(tmp));      res = mysql_store_result(con);//将结果保存在res结构体中      while(row = mysql_fetch_row(res))        {              for(t=0;t<mysql_num_fields(res);t++)              {                printf("%s  ",row[t]);              }              printf(".............\n");              count ++;       }        sprintf(tmp,"insert into %s values(%d,%s,%s,%s)",tablename,3,"123344","143423","1343423"); //注意如何向具有自增字段的数据库中插入记录       rt=mysql_real_query(con,tmp,strlen(tmp));*/       mysql_free_result(res);     //释放资源       mysql_free_result(res1);        mysql_close(con1);     //关闭数据库       mysql_close(con);       system("pause"); }
转载请注明原文地址: https://www.6miu.com/read-36343.html

最新回复(0)