cp.cpp

闲来无事写的一个七星彩的分析程序,数据库为mysql,在winxp与vc2005下编译通过

#include <windows.h>
#include <iostream>
#include <mysql.h>
#include <stdio.h>
#include <string.h>
#pragma comment(lib,"libmysql.lib ")
using namespace std;
void init(MYSQL *sock)
{
    MYSQL *mysql;
    mysql=sock;
    mysql_query(sock,"drop table if exists tjno1");
	mysql_query(sock,"create table tjno1 select no1,count(no1) as tj from lssj group by no1");
    mysql_query(sock,"drop table if exists tjno2");
	mysql_query(sock,"create table tjno2 select no2,count(no2) as tj from lssj group by no2");
	mysql_query(sock,"drop table if exists tjno3");
	mysql_query(sock,"create table tjno3 select no3,count(no3) as tj from lssj group by no3");
	mysql_query(sock,"drop table if exists tjno4");
	mysql_query(sock,"create table tjno4 select no4,count(no4) as tj from lssj group by no4");
	mysql_query(sock,"drop table if exists tjno5");
	mysql_query(sock,"create table tjno5 select no5,count(no5) as tj from lssj group by no5");
	mysql_query(sock,"drop table if exists tjno6");
	mysql_query(sock,"create table tjno6 select no6,count(no6) as tj from lssj group by no6");
	mysql_query(sock,"drop table if exists tjno7");
	mysql_query(sock,"create table tjno7 select no7,count(no7) as tj from lssj group by no7");
}
void tjmax(MYSQL *sock,int i)
{
        MYSQL *mysql;
		MYSQL_RES *results;
        MYSQL_ROW record;

        int n=0,nox;
     	char sql[]="select max(tj) from tjno";
		char sql1[]="select no";
		char sql2[]=" from tjno";
		char sql3[]=" where tj=";

        char temp[255];
        mysql=sock;
        nox=i;
        n=sprintf(temp,"%s",sql);
        n+=sprintf(temp+n,"%d",nox);
		//printf("%s",temp);
        mysql_query(mysql,temp);
	    results=mysql_store_result(mysql);
	    if(record = mysql_fetch_row(results))
         {
		 n=0;
		 //printf("第%d位最多的出现了%s次\n",nox,record[0]);
		 n= sprintf(temp,"%s", sql1 );  
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql2);
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql3);
		 n+=sprintf(temp+n,"%s",record[0]);
		 //printf("%s",temp);
         }

        mysql_query(mysql,temp);
        results=mysql_store_result(mysql);
	
	   while(record = mysql_fetch_row(results))
        {
        printf("第%d位最多的是%s\t",nox,record[0]);
		}
	   printf("\n");
	   mysql_free_result(results);
}
void tjmin(MYSQL *sock,int i)
{
        MYSQL *mysql;
		MYSQL_RES *results;
        MYSQL_ROW record;

        int n=0,nox;
     	char sql[]="select min(tj) from tjno";
		char sql1[]="select no";
		char sql2[]=" from tjno";
		char sql3[]=" where tj=";

        char temp[255];
        mysql=sock;
        nox=i;
        n=sprintf(temp,"%s",sql);
        n+=sprintf(temp+n,"%d",nox);
		//printf("%s",temp);
        mysql_query(mysql,temp);
	    results=mysql_store_result(mysql);
	    if(record = mysql_fetch_row(results))
         {
		 n=0;
		 //printf("第%d位最多的出现了%s次\n",nox,record[0]);
		 n= sprintf(temp,"%s", sql1 );  
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql2);
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql3);
		 n+=sprintf(temp+n,"%s",record[0]);
		 //printf("%s",temp);
         }

        mysql_query(mysql,temp);
        results=mysql_store_result(mysql);
	
	   while(record = mysql_fetch_row(results))
        {
        printf("第%d位最少的是%s\t",nox,record[0]);
		}
	   printf("\n");
	   mysql_free_result(results);
}
void tjave(MYSQL *sock,int i)
{
        MYSQL *mysql;
		MYSQL_RES *results;
        MYSQL_ROW record;

        int n=0,nox,average;
     	char sql[]="select sum(tj) from tjno";
		char sql1[]="select no";
		char sql2[]=" from tjno";
		char sql3[]=" where tj=";

        char temp[255];
        mysql=sock;
        nox=i;
        n=sprintf(temp,"%s",sql);
        n+=sprintf(temp+n,"%d",nox);
	    //printf("%s\n",temp);
        mysql_query(mysql,temp);
	    results=mysql_store_result(mysql);
	    if(record = mysql_fetch_row(results))
         {
		 n=0;
		 average=atoi(record[0])/10;//将数字数组转换成整型数字
		 //printf("%d\n",average);
		 //printf("第%d位最平均的出现了%s次\n",nox,record[0]);
		 n= sprintf(temp,"%s", sql1 );  
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql2);
		 n+=sprintf(temp+n,"%d",nox);
		 n+=sprintf(temp+n,"%s",sql3);
		 n+=sprintf(temp+n,"%d",average);
		 //printf("%s\n",temp);
         }
        mysql_query(mysql,temp);
        results=mysql_store_result(mysql);
	    while(record = mysql_fetch_row(results))
        {
        printf("第%d位最平均的是%s\t",nox,record[0]);
		}
	    printf("\n");
	    mysql_free_result(results);
}
void single_import(MYSQL *sock)
{
MYSQL *mysql;
int i=0;
char n1='o',n2='o',n3='o',n4='o',n5='o',n6='o',n7='o';
char term[7];
char sql[255];
mysql=sock;
printf("请输入要添加的期数(六位):");
scanf("%s",term);
printf("第一位:\t第二位:\t第三位:\t第四位:\t第五位:\t第六位:\t第七位:\n");
cin >>n1;
cout <<'\t';
cin >>n2;
cout <<'\t';
cin >>n3;
cout <<'\t';
cin >>n4;
cout <<'\t';
cin >>n5;
cout <<'\t';
cin >>n6;
cout <<'\t';
cin >>n7;
cout <<endl;
printf("%c\t%c\t%c\t%c\t%c\t%c\t%c\t",n1,n2,n3,n4,n5,n6,n7);
i=sprintf(sql,"%s","insert into lssj(qs,no1,no2,no3,no4,no5,no6,no7) values (");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",term);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n1);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n2);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n3);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n4);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n5);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n6);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",",");
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%c",n7);
i+=sprintf(sql+i,"%s","\"");
i+=sprintf(sql+i,"%s",")");
printf("%s\n",sql);
system("pause");
mysql_query(mysql,sql);
}
void show_lssj(MYSQL *mysql1)
{
char term[7];
int i=0;
MYSQL *mysql;
char sql[255];
MYSQL_RES *results;
MYSQL_ROW record;
mysql=mysql1;
printf("请输入要查询的期数(六位):");
scanf("%s",term);
i=sprintf(sql,"%s","select * from lssj where qs=");
i+=sprintf(sql+i,"%s",term);
/*printf("%s",sql);
system("pause");*/
mysql_query(mysql,sql);
results=mysql_store_result(mysql);
i=0;
while (record = mysql_fetch_row(results))
        {
        printf("第%s期：\t%s\t%s\t%s\t%s\t%s\t%s\t%s \n",record[0],record[1],record[2],record[3],record[4],record[5],record[6],record[7]);
		}
system("pause");
  mysql_free_result(results);

}
void menu(MYSQL *sock)
{
 MYSQL *mysql;
 int choose=0,i=0;

 mysql=sock;
 
 while(choose<8)
{
 system("cls");
 printf("\t\t       七星彩分析软件\n");
 printf("\t1、单期历史数据录入\t2、重新分析\n");
 printf("\t3、显示最高概率数字\t4、显示最低概率数字\n");
 printf("\t5、显示平均概率数字\t6、历史数据查询\n");
 printf("\t7、成批数据导入 \t8、退出\n");
 printf("\t\t请输入您的选择:");
 cin >> choose;
 switch(choose)
 {
 case 1: single_import(mysql);
	 break;
 case 2: init(mysql);
	 break;
 case 3: for(i=1;i<8;i++)
	     {
	      tjmax(mysql,i);
	      }
	 system("pause");
	 break;
 case 4: for(i=1;i<8;i++)
	     {
	      tjmin(mysql,i);
	      }
	 system("pause");//程序暂停显示选择的结果
	 break;
 case 5:for(i=1;i<8;i++)
	    {
	     tjave(mysql,i);
	    }
	 system("pause");
	 break;
 case 6:show_lssj(mysql);
	 break;
 /* case 6:batch_import();
	 break;*/
 }
 }
}

/*void batch_import(MYSQL *sock)
{

}*/
int main()
{
    
    char host[15],user[8],pass[12],db[8];
	printf("请输入数据服务器ip地址:[127.0.0.1]");
	scanf("%s",host);
    printf("请输入数据库用户名:[root]");
	scanf("%s",user);
	printf("请输入用户密码:[]");
	scanf("%s",pass);
	printf("请输入数据库名称:[cp]");
	scanf("%s",db);
    MYSQL *sock;
    sock = mysql_init(0);
    if (sock) 
        cout << "数据库初始化成功" << endl;
    else 
    {
        cout << "数据库初始化失败" << mysql_error(sock) << endl;
    }

    if (mysql_real_connect(sock, host, user, pass, db, 0, NULL, 0))
        cout << "数据库连接成功" << endl;
    else 
    {
        cout << "数据库连接失败: " << mysql_error(sock) << endl;
    }
    mysql_set_character_set(sock,"gb2312");
    
    //connection character set
    cout << "数据库连接字符设置: " << mysql_character_set_name(sock) << endl;
    init(sock);
	menu(sock);
	mysql_close(sock);
    return EXIT_SUCCESS;
}