#include <windows.h>
#include "stdio.h"
#include "winsock.h" 
#include "mysql.h" 
 
int main()
{
    MYSQL * con; //= mysql_init((MYSQL*) 0); 
    MYSQL_RES *res;
    MYSQL_ROW row;
     
     
    char tmp[400];
     
    //database configuartion
    char dbuser[30]="root"; 
    char dbpasswd[30]="apple";
    char dbip[30]="localhost";
    char dbname[50]="excel";
    char tablename[50]="test";
    char *query=NULL;
     
     
    int x;
    int y;
    int rt;//return value
    unsigned int t;
     
    int count = 0;
     
     
    printf("input x,y\n");
    scanf("%d,%d",&x,&y);
    fflush(stdin);
    printf("input over\n");
    con = mysql_init((MYSQL*) 0); 
     
     
    if ( con !=NULL && mysql_real_connect(con,dbip,dbuser,dbpasswd,dbname,3306/*TCP IP端口*/,NULL/*Unix Socket 连接类型*/,0/*运行成ODBC数据库标志*/) 
    { 
        if (!mysql_select_db(con,dbname)) 
        { 
            printf("Select successfully the database!\n"); 
            
            con ->reconnect = 1; 
            
            query = "set names \\'GBK\\'";
            //mysql_query(con,"set names \\'GBK\\'"); 
            
            rt=mysql_real_query(con,query,strlen(query));
            if (rt)
            {
                printf("Error making query: %s !!!\n",mysql_error(con));
            }
            else
            {
                printf("query %s succeed!\n",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,"insert into %s values(%s,%d,%d)",tablename,"null",x,y); //注意如何向具有自增字段的数据库中插入记录
    //MessageBoxA(NULL,tmp,tmp,MB_OK);
    //mysql_query(con,tmp);
    
    rt=mysql_real_query(con,tmp,strlen(tmp));
    if (rt)
    {
        printf("Error making query: %s !!!\n",mysql_error(con));
    }
    else
    {
        printf("%s executed!!!\n",tmp);
    }
    
    sprintf(tmp,"select * from %s",tablename);
    
    rt=mysql_real_query(con,tmp,strlen(tmp));
    if (rt)
    {
        printf("Error making query: %s !!!\n",mysql_error(con));
    } 
    else
    {
        printf("%s executed!!!\n",tmp);
    }
    
    res = mysql_store_result(con);//将结果保存在res结构体中
    
    while(row = mysql_fetch_row(res))  
    {  
        /** 
        * MYSQL_ROW STDCALL mysql_fetch_row(MYSQL_RES *result); 
        * 检索行 
        */  
        
        for(t=0;t<mysql_num_fields(res);t++)  
        {  
            printf("%s  ",row[t]);  
        }  
        printf(".............\n");  
        count ++;
    }  
    printf("number of rows %d\n",count);
    printf("mysql_free_result...\n");  
    mysql_free_result(res);  
    
    mysql_close(con);
    return 0;

}

/*
Navicat MySQL Data Transfer

Source Server         : localhost
Source Server Version : 50141
Source Host           : localhost:3306
Source Database       : excel

Target Server Type    : MYSQL
Target Server Version : 50141
File Encoding         : 65001

Date: 2011-09-23 10:41:43
*/
 
 

  SET FOREIGN_KEY_CHECKS=0;
  -- ----------------------------
  -- Table structure for `test`
  -- ----------------------------
  DROP TABLE IF EXISTS `test`;
  CREATE TABLE `test` (
    `x` bigint(4) NOT NULL AUTO_INCREMENT,
    `y` int(4) DEFAULT NULL,
    `z` int(4) DEFAULT NULL,
    PRIMARY KEY (`x`)
  ) ENGINE=InnoDB AUTO_INCREMENT=118 DEFAULT CHARSET=latin1;
   
  -- ----------------------------
  -- Records of test
  -- ----------------------------
  INSERT INTO `test` VALUES (\'95\', \'12432\', \'4334\');
  INSERT INTO `test` VALUES (\'96\', \'213\', \'321\');
  INSERT INTO `test` VALUES (\'97\', \'213\', \'213\');
  INSERT INTO `test` VALUES (\'98\', \'123\', \'231\');
  INSERT INTO `test` VALUES (\'99\', \'321\', \'231\');
  INSERT INTO `test` VALUES (\'100\', \'123\', \'32132\');
  INSERT INTO `test` VALUES (\'101\', \'777\', \'32213\');
  INSERT INTO `test` VALUES (\'102\', \'123\', \'213\');
  INSERT INTO `test` VALUES (\'103\', \'21\', \'321\');
  INSERT INTO `test` VALUES (\'104\', \'324\', \'432\');
  INSERT INTO `test` VALUES (\'105\', \'132\', \'231\');
  INSERT INTO `test` VALUES (\'106\', \'324\', \'342\');
  INSERT INTO `test` VALUES (\'107\', \'23\', \'23\');
  INSERT INTO `test` VALUES (\'108\', \'12\', \'21\');
  INSERT INTO `test` VALUES (\'109\', \'231\', \'321\');
  INSERT INTO `test` VALUES (\'110\', \'123\', \'231\');
  INSERT INTO `test` VALUES (\'111\', \'123\', \'231\');
  INSERT INTO `test` VALUES (\'112\', \'123\', \'123\');
  INSERT INTO `test` VALUES (\'113\', \'312\', \'231\');
  INSERT INTO `test` VALUES (\'114\', \'312\', \'321\');
  INSERT INTO `test` VALUES (\'115\', \'23\', \'3\');
  INSERT INTO `test` VALUES (\'116\', \'213\', \'312\');
  INSERT INTO `test` VALUES (\'117\', \'2\', \'3\');
   
  -- ----------------------------
  -- Table structure for `xqdata`
  -- ----------------------------
  DROP TABLE IF EXISTS `xqdata`;
  CREATE TABLE `xqdata` (
    `代码` varchar(20) NOT NULL DEFAULT \'\',
    `商品` varchar(20) CHARACTER SET utf8 DEFAULT NULL,
    `卖出` bigint(20) DEFAULT NULL,
    `成交` bigint(20) DEFAULT NULL,
    `涨跌` bigint(20) DEFAULT NULL,
    `买进` bigint(20) DEFAULT NULL,
    `总量` bigint(20) DEFAULT NULL,
    `涨幅` double DEFAULT NULL,
    `时间` time DEFAULT NULL,
    PRIMARY KEY (`代码`)
  ) ENGINE=InnoDB DEFAULT CHARSET=latin1;
   
  -- ----------------------------
  -- Records of xqdata
  -- ----------------------------
  INSERT INTO `xqdata` VALUES (\'FITX*1\', \'商品\', \'34\', \'43\', \'23\', \'34\', \'0\', \'1.4\', \'13:23:08\');