sql-example.rar_mfc开发sql_sql MFC

#include <IOSTREAM> #include <STRING> #include <SSTREAM> #include "sqlite3.h" using namespace std; static int num=0; sqlite3* pDB; static int callback(void *NotUsed, int argc, char **argv, char **azColName){ int i; for(i=0; i<argc;i++) { std::cout<< ++num<< " = "<< (argv[i] ? argv[i] : "NULL"); } std::cout<< "\n"; return 0; } void gongneng() { cout<<"*********************************************************\n"; cout<<" 1. 显示功能项\n"; cout<<" 2. 显示所有的表\n"; cout<<" 3. 查询要查的表名\n"; cout<<" 4. 插入你要插入的值\n"; cout<<" 5. 更新你要更新表的值\n"; cout<<" 6. 删除你要表值的值\n"; cout<<"*********************************************************\n"; } int select1() { char* errMsg; string strSQL= "select name from sqlite_master where type='table'"; int res = sqlite3_exec(pDB,strSQL.c_str(),callback,0, &errMsg); num=0; if (res != SQLITE_OK) { std::cout << "执行SQL 出错." << errMsg << std::endl; return -1; } else { std::cout << "SQL成功执行."<< std::endl; } return 0; } int select2(string var) { char *errMsg; char **resultp; /* Result written to a char *[] that this points to */ int nrow; /* Number of result rows written here */ int ncolumn; /* Number of result columns written here */ string strSQL= "select * from " + var + ";"; int res = sqlite3_get_table(pDB,strSQL.c_str(),&resultp, &nrow, &ncolumn, &errMsg); for(int i=0; i <=nrow; i++) { for(int j=0; j <ncolumn; j++) { /* the i+1 term skips over the first record, which is the column headers */ cout<<resultp[i*ncolumn + j]<<" "; }cout<<endl; } if (res != SQLITE_OK) { std::cout << "执行SQL 出错." << errMsg << std::endl; return -1; } else { std::cout << "SQL成功执行."<< std::endl; } return 0; } int insert(string var) { char *errMsg; char **resultp; /* Result written to a char *[] that this points to */ int nrow; /* Number of result rows written here */ int ncolumn; /* Number of result columns written here */ string x; string y; string p; cout<<"请输入你的值:\n"; cin>>x>>y>>p; cout<<endl; string strSQL= "insert into " + var + " values ('" + x + "','" + y + "','" + p + "');"; int res = sqlite3_get_table(pDB,strSQL.c_str(),&resultp, &nrow, &ncolumn, &errMsg); /*for(int i=0; i <=nrow; i++) { for(int j=0; j <ncolumn; j++) { /* the i+1 term skips over the first record, which is the column headers */ //cout<<resultp[i*ncolumn + j]<<" "; //}cout<<endl; //}*/ if (res != SQLITE_OK) { std::cout << "执行SQL 出错." << errMsg << std::endl; return -1; } else { std::cout << "SQL成功执行."<< std::endl; } return 0; } int delete1(string var) { char *errMsg; char **resultp; /* Result written to a char *[] that this points to */ int nrow; /* Number of result rows written here */ int ncolumn; /* Number of result columns written here */ string x; string y; string p; cout<<"请输入你要删除的字段:\n"; cin>>x; cout<<"请输入你要删除的值:\n"; cin>>y; cout<<endl; string strSQL= "delete from " + var + " where " + x + " = '" + y + "';"; int res = sqlite3_get_table(pDB,strSQL.c_str(),&resultp, &nrow, &ncolumn, &errMsg); /*for(int i=0; i <=nrow; i++) { for(int j=0; j <ncolumn; j++) { /* the i+1 term skips over the first record, which is the column headers */ //cout<<resultp[i*ncolumn + j]<<" "; //}cout<<endl; //}*/ if (res != SQLITE_OK) { std::cout << "执行SQL 出错." << errMsg << std::endl; return -1; } else { std::cout << "SQL成功执行."<< std::endl; } return 0; } int update(string var) { char *errMsg; char **resultp; /* Result written to a char *[] that this points to */ int nrow; /* Number of result rows written here */ int ncolumn; /* Number of result columns written here */ string m; string n; //string q; string k; cout<<"请输入要更新的字段:\n"; cin>>m; cout<<"请输入要更新的新值:\n"; cin>>n; cout<<"请输入要更新的旧值:\n"; cin>>k; cout<<endl; string strSQL= "update " + var + " set " + m + " = " + n + " where " + m + " = " + k; int res = sqlite3_get_table(pDB,strSQL.c_str(),&resultp, &nrow, &ncolumn, &errMsg); /*for(int i=0; i <=nrow; i++) { for(int j=0; j <ncolumn; j++) { /* the i+1 term skips over the first record, which is the column headers */ //cout<<resultp[i*ncolumn + j]<<" "; //}cout<<endl; //} if (res != SQLITE_OK) { std::cout << "执行SQL 出错." << errMsg << std::endl; return -1; } else { std::cout << "SQL成功执行."<< std::endl; } return 0; } int main(int argc, char **) { /*if (argc < 2) { std::cout << "请输入命令行参数：sqlite数据库名." << std::endl; return 0; }*/ int res = sqlite3_open("me.db", &pDB); if( res ){ std::cout << "Can't open database: "<< sqlite3_errmsg(pDB); sqlite3_close(pDB); return -1; } system("cls"); while(1){ cout<<"*********************************************************\n"; cout<<" 1. 显示功能项\n"; cout<<" 2. 显示所有的表\n"; cout<<" 3. 查询要查的表名\n"; cout<<" 4. 插入你要插入的值\n"; cout<<" 5. 更新你要更新表的值\n"; cout<<" 6. 删除你要表值的值\n"; cout<<" 7. 退出程序\n"; cout<<"*********************************************************\n"; //select1(); int data; string var; cout<<"请输入序号:"<<endl; cin>>data; if(data==1) { gongneng(); } if(data==2) { system("cls"); select1(); } if(data==3){ system("cls"); cout<<"请输入您要查询的表名：\n"; cin>>var; cout<<endl; select2(var); } if(data==4) { system("cls"); cout<<"请输入您要插入值的表：\n"; cin>>var; insert(var); } if(data==5) { system("cls"); cout<<"请输入你要更新的值的表：\n"; cin>>var; update(var); } if(data==6) { system("cls"); cout<<"删除你要表值的值：\n"; cin>>var; delete1(var); } if(data==7) { return 0; } //system("cls"); } return 0; }