#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("请