前言
本文给大家展示的代码实际上就是如何利用Sqlite3的参数化机制做数据插入,也可以update操作,就看你怎么玩了,这里只列出代码,然后说一些注意事项。
下面的代码,有一个问题,插入后的东西一定是:
1 |
INSERT INTO "work" VALUES ( '铪' , '铪铪铪铪铪' , NULL , NULL , NULL , NULL , '铪铪铪铪铪' , NULL , NULL ,110.0,1.0,108.9, NULL , NULL , '铪铪铪铪铪' , NULL , NULL , NULL , '铪铪铪铪铪' , NULL , NULL , NULL ); |
看看有问题的代码:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 |
sqlite3_stmt *stmt; CString sql = "insert into work values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)" ; int rc = sqlite3_prepare_v2(db, sql.GetString(), -1, &stmt, NULL );
if(rc != SQLITE_OK) { MessageBox( "sqlite3_prepare_v2 Failed!" ); return ; }
count = 0; p_wnd = PrevWnd;
while( count ++ < ID_TOTALCOUNT) { CString DbStr;
p_wnd = CWnd::GetNextDlgTabItem(p_wnd, FALSE ); if(p_wnd == NULL ) { return ; }
p_wnd->GetWindowText(DbStr);
do { if(!DbStr.GetLength()) { rc = sqlite3_bind_null(stmt, count ); break; }
//日期相关 if( count == ID_CHUDANRIQI || count == ID_CHUFARIQI || count == ID_HUANKUANRIQI || count == ID_HUOLIRIQI) { CDateTimeCtrl *TimeCtl = (CDateTimeCtrl *)p_wnd; CString time = DateTimeToString(*TimeCtl);
rc = sqlite3_bind_text(stmt, count , time .GetString(), time .GetLength(), SQLITE_STATIC); break; } else { //金钱相关的处理 real 类型 if( count == ID_BAOXIANJINE || count == ID_YONGJINBILV || count == ID_JINGBAOFEI || count == ID_HUANKUANJINE || count == ID_LIRUNBILV || count == ID_LIRUNJINE) { double tMoney = 0.0; int rtn = sscanf_s(DbStr.GetString(), "%lf" , &tMoney);
ASSERT(rtn == 1);
rc = sqlite3_bind_double(stmt, count , tMoney); } else { char *str = ( char *)DbStr.GetString(); int c = strlen(str); int c1 = DbStr.GetLength();
rc = sqlite3_bind_text(stmt, count , DbStr.GetString(), -1/*DbStr.GetLength()*/, SQLITE_STATIC); } } }while(0);
if(rc != SQLITE_OK) { CString ErrStr = sqlite3_errstr(rc); MessageBox(ErrStr);
return ; } }
rc = sqlite3_step(stmt);
if(rc != SQLITE_DONE) { if(rc == SQLITE_ERROR) { CString DbErr; DbErr.Format( "Sql Insert failed, %s" , sqlite3_errmsg(db));
MessageBox(DbErr); } else { MessageBox( "sqlite3_step Failed!" ); } }
sqlite3_finalize(stmt); |
为什么呢?
因为,sqlite3_bind_text绑定的text,需要在做:
1 |
rc = sqlite3_step(stmt); |
的时候统一提交,而上面的代码使用的临时变量, rc = sqlite3_step(stmt); 的时候,早就不存在了。因此乱码也是正常的。
修改如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 |
sqlite3_stmt *stmt; CString sql = "insert into work values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)" ; int rc = sqlite3_prepare_v2(db, sql.GetString(), -1, &stmt, NULL );
if(rc != SQLITE_OK) { MessageBox( "sqlite3_prepare_v2 Failed!" ); return ; }
count = 0; p_wnd = PrevWnd;
CString DbStr[ID_TOTALCOUNT + 1];
while( count ++ < ID_TOTALCOUNT) { DbStr[ count ].Empty();
p_wnd = CWnd::GetNextDlgTabItem(p_wnd, FALSE ); if(p_wnd == NULL ) { return ; }
p_wnd->GetWindowText(DbStr[ count ]);
do { if(!DbStr[ count ].GetLength()) { rc = sqlite3_bind_null(stmt, count ); break; }
//日期相关 if( count == ID_CHUDANRIQI || count == ID_CHUFARIQI || count == ID_HUANKUANRIQI || count == ID_HUOLIRIQI) { CDateTimeCtrl *TimeCtl = (CDateTimeCtrl *)p_wnd; CString time = DateTimeToString(*TimeCtl);
DbStr[ count ] = time ;
rc = sqlite3_bind_text(stmt, count , time .GetString(), time .GetLength(), SQLITE_STATIC); } else { //金钱相关的处理 real 类型 if( count == ID_BAOXIANJINE || count == ID_YONGJINBILV || count == ID_JINGBAOFEI || count == ID_HUANKUANJINE || count == ID_LIRUNBILV || count == ID_LIRUNJINE) { double tMoney = 0.0; int rtn = sscanf_s(DbStr[ count ].GetString(), "%lf" , &tMoney);
ASSERT(rtn == 1);
rc = sqlite3_bind_double(stmt, count , tMoney); } else { rc = sqlite3_bind_text(stmt, count , DbStr[ count ].GetString(), DbStr[ count ].GetLength(), SQLITE_STATIC); } } }while(0);
if(rc != SQLITE_OK) { CString ErrStr = sqlite3_errstr(rc); MessageBox(ErrStr);
return ; } }
rc = sqlite3_step(stmt);
if(rc != SQLITE_DONE) { if(rc == SQLITE_ERROR) { CString DbErr; DbErr.Format( "Sql Insert failed, %s" , sqlite3_errmsg(db));
MessageBox(DbErr); } else { MessageBox( "sqlite3_step Failed!" ); } }
sqlite3_finalize(stmt); |
附上数据库创建的sql语法:
1 2 3 4 5 6 |
sqlite> .dump work PRAGMA foreign_keys= OFF ; BEGIN TRANSACTION ; CREATE TABLE work (baodanhao text unique primary key , chudanriqi text,qudao text,lianxiren text,xiaoshou text,beibaorenxingming text,chufar iqi text,baoxianpinpai text,baoxianjihua text,baoxianjine real ,yongjinbilv real ,jingbaofei real ,huankuanfangshi text,haikuanjine real ,huanku anriqi text,shifouquane text,lirunbilv real ,lirunjine real ,huoliriqi text,fapiaojisong text,shifubaoxiangongsi text,beizhu text); |
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对服务器之家的支持。
原文链接:http://www.doocr.com/articles/58a875ac8d4f1f3990989f38
查看更多关于SQLite3的绑定函数族使用与其注意事项详解的详细内容...