分享一段ios数据库代码。包括创建、升级、增删查改。
里面的那些类不必细究，主要是数据库的代码100%可用。
数据库升级部分，使用switch，没有break，低版本一次向高版本修改。
// DB.h
//iukey
#import
#import "sqlite3.h"
#import "User.h"
#import "ChatInfo.h"
#import "DescInfo.h"
@interface DBHelper : NSObject{
sqlite3* db;//数据库句柄
// @public DBHelper *instance;
}
@property(nonatomic,assign)sqlite3* db;
- (BOOL)insertUserWithTUsersName:(NSString*)name account:(NSString*)account pwd:(NSString*)pwd;
- (NSMutableArray*)quary:(NSString*)str;//查询
- (NSString*)getFilePath;//获取数据库路径
- (BOOL)createDB;//创建数据库
- (BOOL)createTable:(NSString*) creteSql;//创建表
- (User*)getUserWithTUsersByAccount:(NSString* )account;
- (BOOL)updateUserPwdWithTUsers:(NSString*)pwd byAccount:(NSString*)account ;
//+ (DBHelper*) getDBhelperInstance;
- (BOOL)deleteItemWithTable:(NSString*)table_ ByKey:(NSString*)key_ ;
-(BOOL)insertChatRecordWithTChatRecordByChatInfo:(ChatInfo*)ci owner:(NSString *)owner;
- (int)getRecordCountWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid owner:(NSString *)owner;
- (NSMutableArray*)getChatInfoWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid fromIndex:(int)fromIndex count:(int)count owner:(NSString *)owner;
- (BOOL)deleteChatInfoWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid owner:(NSString *)owner;
-(NSMutableDictionary*)getRecordCountNotREadWithTChatRecord:(NSString*)toJid owner:(NSString *)owner;
-(BOOL)updateRecordCountNotReadWithChatRecord:(NSString *)fromJid;
-(NSMutableArray*)getRecordNotReadWithTChatRecordFromJid:(NSString*)fromJid owner:(NSString *)owner;
//history
-(BOOL)insertHistoryRecordWithTHistoryRecordByDescInfo:(DescInfo*)di account:(NSString*)account routerjid:(NSString *)routerjid;
- (NSMutableArray*)getHistoryRecordWithTHistoryRecordByAccount:(NSString* )account routerjid:(NSString *)routerjid;
- (BOOL)deleteHistoryWithTHistoryRecordByDeviceType:(NSString *)deviceType account:(NSString* )account routerjid:(NSString *)routerjid;
- (BOOL)deleteHistoryWithTHistoryRecordById:(int)c_id account:(NSString* )account routerjid:(NSString *)routerjid;
- (NSMutableArray*)getHistoryRecordWithTHistoryRecordByUDN:(NSString* )UDN withAccount:(NSString* )account routerjid:(NSString *)routerjid;
-(BOOL)updateHistoryCountNotReadWithHistoryRecordByDeviceType:(NSString *)deviceType account:(NSString* )account routerjid:(NSString *)routerjid;
-(int)getHistoryCountNotReadWithHistoryRecordByAccount:(NSString *)account routerjid:(NSString *)routerjid;
@end
// DB.m
//iukey
#import "DBHelper.h"
#import "YHConfig.h"
#import "DescInfo.h"
#import "FromJid.h"
// tid ----table index id
@implementation DBHelper
static NSString *createTB_user=@"create table if not exists t_users (c_account text primary key ,c_name text,c_pwd text)";
static NSString *createTB_info=@"create table if not exists t_info (c_key text primary key ,c_value text)";
static NSString *createTB_chat_record=@"create table if not exists t_chat_record (c_id integer primary key autoincrement,c_from_jid text,c_to_jid text,c_chat_time integer,c_msg text,c_has_read integer)";
static NSString *createTB_history_record=@"create table if not exists t_history_record (c_id integer primary key autoincrement,c_deviceType text,c_UDN text,c_friendlyName text,c_history_time integer,c_desc text)";
@synthesize db;
- (id)init{
self = [super init];
int dbVersion =0;
//检查是否存在数据库文件
if (![self isExistDB]) {
//不存在，则创建
[self createDB];
}else {
//若存在，检测数据库版本，则进行升级，
char* info=NULL;
[self getDBInfoValueWithKey:"db_version" value:&info];
if(info == NULL){
return self;
}
dbVersion= atoi(info);
free (info);
}
//升级数据库。若第一次创建，则从0开始升级。顺序升级，因此不可以有break
switch (dbVersion) {
case 0:
//第一次，新建并初始化各表
[self createTable:createTB_user];
//记录版本
[self createTable:createTB_info];
[self setDBInfoValueWithKey:"db_version" value:"1"];
[self createTable:createTB_chat_record];
[self createTable:createTB_history_record];
case 1:
[self setDBInfoValueWithKey:"db_version" value:"2"];
case 2:
{
NSString *modify=@"alter table t_history_record add column c_user text not null default ‘‘";
[self setDBInfoValueWithKey:"db_version" value:"3"];
[self execSql:modify];
}
case 3:
{
NSString *modify=@"alter table t_chat_record add column c_owner text not null default ‘‘";
[self setDBInfoValueWithKey:"db_version" value:"4"];
[self execSql:modify];
}
case 4:
{
NSString *modify=@"alter table t_history_record add column c_router text not null default ‘‘";
[self setDBInfoValueWithKey:"db_version" value:"5"];
[self execSql:modify];
}
case 5:
{
NSString *modify=@"alter table t_history_record add column c_has_read integer not null default ‘‘";
[self setDBInfoValueWithKey:"db_version" value:"6"];
[self execSql:modify];
}
//注：数据库升级时候，只需要一次添加case即可，同时更新db_version值
default:
break;
}
return self;
}
- (NSString*)getFilePath{//get db path
NSArray *documentsPaths=NSSearchPathForDirectoriesInDomains(NSDocumentDirectory , NSUserDomainMask , YES);
NSString *databaseFilePath=[[documentsPaths objectAtIndex:0] stringByAppendingPathComponent:[YHConfig DBName ]];
return databaseFilePath ;
}
#pragma mark db manage
- (BOOL)createDB{
int ret = sqlite3_open([[self getFilePath] UTF8String], &db);//打开数据库，数据库不存在则创建
if (SQLITE_OK == ret) {//创建成功
sqlite3_close(db);//关闭
return YES;
}else{
return NO;//创建失败
}
}
-(BOOL) isExistDB{
NSFileManager* fm = [[[NSFileManager alloc] init]autorelease];
return [fm fileExistsAtPath:[self getFilePath] ];
}
- (BOOL)dropTableWithTableName:(NSString*) tableName{
NSString* dropSql = [[NSString alloc] initWithFormat:@"delete table %@",tableName];
return [self execSql:[dropSql autorelease]];
}
- (BOOL)createTable:(NSString*) creteSql{
return [self execSql:creteSql];
}
-(BOOL) execSql:(NSString*) creteSql{
char* err;
const char* sql = [creteSql UTF8String];//创建表语句
if (sql==NULL) {
return NO;
}
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){
return NO;
}
if (SQLITE_OK == sqlite3_exec(db, sql, NULL, NULL, &err)) {//执行创建表语句成功
sqlite3_close(db);
return YES;
}else{//创建表失败
return NO;
}
}
//"select * from dictionary where en like ? or cn like ? or comment like ?;";//查询语句
//TODO
- (NSMutableArray*)quary:(NSString *) querySql{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){
return nil;
}
const char* sql = [querySql UTF8String];//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
// sqlite3_bind_text(stmt, 1,[[NSString stringWithFormat:@"%%%@%%",str]UTF8String], -1, NULL);
// sqlite3_bind_text(stmt, 2, [[NSString stringWithFormat:@"%%%@%%",str]UTF8String], -1, NULL);
// sqlite3_bind_text(stmt, 3, [[NSString stringWithFormat:@"%%%@%%",str]UTF8String], -1, NULL);
}else{
return nil;
}
NSMutableArray* arr =[[NSMutableArray alloc]init];//存放查询结果
while( SQLITE_ROW == sqlite3_step(stmt) ){//执行
char* _en = (char*)sqlite3_column_text(stmt, 1);
char* _cn = (char*)sqlite3_column_text(stmt, 2);
char* _comment = (char*)sqlite3_column_text(stmt, 3);
NSMutableDictionary* dict = [[NSMutableDictionary alloc]init];//单条纪录
[dict setObject:[NSString stringWithCString:_en encoding:NSUTF8StringEncoding] forKey:@"kEN"];
[dict setObject:[NSString stringWithCString:_cn encoding:NSUTF8StringEncoding] forKey:@"kCN"];
[dict setObject:[NSString stringWithCString:_comment encoding:NSUTF8StringEncoding] forKey:@"kCOMMENT"];
[arr addObject:dict];//插入到结果数组
[dict release];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return [arr autorelease];//返回查询结果数组
}
#pragma mark table t_info manage
- (void)getDBInfoValueWithKey:(const char*)key value:(char**)value{
//TODO
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
printf("%s:%d query error..\n",__FUNCTION__,__LINE__);
return ;
}
const char* sql = "select * from t_info where c_key =?";//查询语句
sqlite3_stmt* stmt;
int error = sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
if (error==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,key, -1, NULL);
}else{
printf("%s:%d query error.. %d\n",__FUNCTION__,__LINE__,error);
return;
}
if( SQLITE_ROW == sqlite3_step(stmt) ){//执行
char* v= (char*)sqlite3_column_text(stmt, 1);
*value = strdup(v);
}
sqlite3_finalize(stmt);
sqlite3_close(db);
}
- (BOOL)setDBInfoValueWithKey:(const char*)key value:(const char*)value {
char* info=NULL;
[self getDBInfoValueWithKey:key value:&info];
if (info!= NULL) {
//存在，则更新
[self updateDBInfoValueWithKey:key value:value];
}else{
//不存在，插入
[self insertDBInfoValueWithKey:key value:value];
}
free(info);
return YES;
}
- (BOOL)insertDBInfoValueWithKey:(const char*)key value:(const char*)value{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){
return NO;
}
const char* sql = "insert into t_info(c_key,c_value) values(?,?);";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, key, -1, NULL);//绑定参数
sqlite3_bind_text(stmt, 2, value, -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
- (BOOL)updateDBInfoValueWithKey:(const char*)key value:(const char*)value{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){
return NO;
}
const char* sql = "update t_info set c_value = ? where c_key = ?;";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, value, -1, NULL);
sqlite3_bind_text(stmt, 2, key, -1, NULL);
}else{
return NO;
}
ret = sqlite3_step(stmt);
printf("ret:%d\n",ret);
if (SQLITE_DONE ==ret ) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
#pragma mark table "t_users" manage
- (User*)getUserWithTUsersByAccount:(NSString* )account{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "select * from t_users where c_account = ?";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[account UTF8String], -1, NULL);
}else{
return nil;
}
User* user = nil;
if( SQLITE_ROW == sqlite3_step(stmt) ){//执行
user = [[[User alloc]init]autorelease];
NSString *name=nil;
NSString *pwd= nil;
if (sqlite3_column_text(stmt, 0) != NULL) {
name = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 0)];
}
if (sqlite3_column_text(stmt,2 ) != NULL) {
pwd = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 2)];
}
user.name =name;
user.account= account;
user.pwd = pwd;
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return user;
}
- (BOOL)insertUserWithTUsersName:(NSString*)name account:(NSString*)account pwd:(NSString*)pwd{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
const char* sql = "insert into t_users(c_name,c_account,c_pwd) values(?,?,?);";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [name UTF8String], -1, NULL);//绑定参数
sqlite3_bind_text(stmt, 2, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3, [pwd UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
//根据account 修改用户 的name和pwd
- (BOOL)updateUserPwdWithTUsers:(NSString*)pwd byAccount:(NSString*)account {
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
const char* sql = "update t_users set c_pwd = ? where c_account = ?";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [pwd UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2, [account UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
#pragma mark table "t_chat_record" manage
-(BOOL)insertChatRecordWithTChatRecordByChatInfo:(ChatInfo*)ci owner:(NSString *)owner{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
//@"create table if not exists t_chat_record (c_id text primary key ,c_from_jid text,c_to_jid text,c_chat_time integer,c_msg text)";
const char* sql = "insert into t_chat_record(c_from_jid,c_to_jid,c_chat_time,c_msg,c_has_read,c_owner) values(?,?,?,?,?,?);";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [[ci fromJid] UTF8String], -1, NULL);//绑定参数
sqlite3_bind_text(stmt, 2, [[ci toJid] UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 3, (int)[ci.chatTime timeIntervalSince1970] );
sqlite3_bind_text(stmt, 4, [ci.msg UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 5, [ci hasRead]);
sqlite3_bind_text(stmt, 6, [owner UTF8String], -1, NULL);
log4debug(@"%d",[ci hasRead]);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
//update the count of chat record not read
-(BOOL)updateRecordCountNotReadWithChatRecord:(NSString *)fromJid
{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "update t_chat_record set c_has_read = 1 where c_from_jid = ?";//修改语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1, [fromJid UTF8String], -1, NULL);
}else{
return nil;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
-(NSMutableArray*)getRecordNotReadWithTChatRecordFromJid:(NSString*)fromJid owner:(NSString *)owner{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "select c_chat_time,c_msg from t_chat_record where c_has_read = 0 and c_from_jid =? and c_owner =? order by c_chat_time asc";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[fromJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[owner UTF8String], -1, NULL);
}else{
return nil;
}
NSMutableArray* msgs=[[[NSMutableArray alloc]init]autorelease];
while ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
NSString *msg=nil;
int chatTime = 0;
if (sqlite3_column_text(stmt, 1) != NULL) {
msg = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 1)];
}
chatTime = sqlite3_column_int(stmt, 0);
NSDate * showTime = [NSDate dateWithTimeIntervalSince1970:chatTime];
[msgs addObject:showTime];
[msgs addObject:msg];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return msgs ;
}
//get the count of the chat record not read
-(NSMutableDictionary*)getRecordCountNotREadWithTChatRecord:(NSString*)toJid owner:(NSString *)owner
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "select c_from_jid, count(*) from t_chat_record where c_has_read = 0 and c_to_jid =? and c_owner =? group by c_from_jid ";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[toJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[owner UTF8String], -1, NULL);
}else{
return nil;
}
NSMutableDictionary* fis=[[[NSMutableDictionary alloc]init]autorelease];
while ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
FromJid* fi = [[[FromJid alloc]init]autorelease];
NSString *fromJid=nil;
int noReadCount = 0;
if (sqlite3_column_text(stmt, 0) != NULL) {
fromJid = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 0)];
}
noReadCount = sqlite3_column_int(stmt, 1);
fi.fromJid = fromJid;
fi.noReadCount = noReadCount;
[fis setObject:fi forKey:fi.fromJid];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return fis ;
}
//get the count of the chat record
- (int)getRecordCountWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid owner:(NSString *)owner
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
//static NSString *[email protected]"create table if not exists t_chat_record (c_id integer primary key autoincrement,c_from_jid text,c_to_jid text,c_chat_time integer,c_msg text)";
//不区分from&to，因此两个条件查询
const char* sql = "select count (*) from t_chat_record where ((c_from_jid = ? and c_to_jid=?) or (c_from_jid = ? and c_to_jid=?)) and c_owner = ?";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 4,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 5,[owner UTF8String], -1, NULL);
}else{
return nil;
}
int count=0;
if ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
count=sqlite3_column_int(stmt, 0);
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return count ;
}
- (NSMutableArray*)getChatInfoWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid fromIndex:(int)fromIndex count:(int)count owner:(NSString *)owner
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
//static NSString *[email protected]"create table if not exists t_chat_record (c_id integer primary key autoincrement,c_from_jid text,c_to_jid text,c_chat_time integer,c_msg text)";
//不区分from&to，因此两个条件查询
const char* sql = "select * from t_chat_record where ((c_from_jid = ? and c_to_jid=?) or (c_from_jid = ? and c_to_jid=?)) and c_owner = ? order by c_chat_time asc limit ?,? ";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 4,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 5,[owner UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 6, fromIndex);
sqlite3_bind_int(stmt, 7, count);
}else{
return nil;
}
NSMutableArray *cis=[[[NSMutableArray alloc]initWithCapacity:3]autorelease];
while ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
ChatInfo* ci = [[[ChatInfo alloc]init]autorelease];
NSString *fromJid=nil;
NSString *toJid= nil;
NSString *msg=nil;
int time = 0;
if (sqlite3_column_text(stmt, 1) != NULL) {
fromJid = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 1)];
}
if (sqlite3_column_text(stmt,2 ) != NULL) {
toJid = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 2)];
}
if (sqlite3_column_text(stmt,3 ) != NULL) {
time = sqlite3_column_int(stmt, 3);
}
if (sqlite3_column_text(stmt,4 ) != NULL) {
msg = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 4)];
}
ci.fromJid=fromJid;
ci.toJid=toJid;
ci.chatTime=[NSDate dateWithTimeIntervalSince1970:time];
ci.msg=msg;
[cis addObject:ci];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return cis ;
}
- (BOOL)deleteChatInfoWithTChatRecordByoneJid:(NSString* )oneJid anotherJid:(NSString* )anotherJid owner:(NSString *)owner
{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
NSString* sql = [NSString stringWithFormat:@"delete from t_chat_record where ((c_from_jid = ? and c_to_jid=?) or (c_from_jid = ? and c_to_jid=?)) and c_owner = ?"];
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3,[anotherJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 4,[oneJid UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 5,[owner UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
#pragma mark table "t_history_record" manage
-(BOOL)insertHistoryRecordWithTHistoryRecordByDescInfo:(DescInfo*)di account:(NSString*)account routerjid:(NSString *)routerjid{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
//@"create table if not exists t_history_record (c_id text primary key ,c_deviceType text,c_UDN text,c_friendlyName text,c_history_time integer,c_desc text)";
const char* sql = "insert into t_history_record(c_deviceType,c_UDN,c_friendlyName,c_history_time,c_desc,c_user,c_router,c_has_read) values(?,?,?,?,?,?,?,?);";
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, sql, -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [[di deviceType] UTF8String], -1, NULL);//绑定参数
sqlite3_bind_text(stmt, 2, [[di deviceUDN] UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3, [[di friendlyName] UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 4, (int)[di.time timeIntervalSince1970] );
sqlite3_bind_text(stmt, 5, [di.deviceDesc UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 6, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 7, [routerjid UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 8, [di hasRead]);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
- (NSMutableArray*)getHistoryRecordWithTHistoryRecordByUDN:(NSString* )UDN withAccount:(NSString* )account routerjid:(NSString *)routerjid
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "select * from t_history_record where c_UDN = ? and c_user =? and c_router =? order by c_history_time desc";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[UDN UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3,[routerjid UTF8String], -1, NULL);
}else{
return nil;
}
NSMutableArray *dis=[[[NSMutableArray alloc]initWithCapacity:5]autorelease];
while ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
DescInfo* di = [[[DescInfo alloc]init]autorelease];
NSString* deviceType = nil;
NSString* friendlyName= nil;
NSString* deviceUDN= nil;
NSString* deviceDesc= nil;
NSDate* time= nil;
int c_id = 0;
if (sqlite3_column_text(stmt, 0) != NULL) {
c_id = sqlite3_column_int(stmt, 0);
}
if (sqlite3_column_text(stmt, 1) != NULL) {
deviceType = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 1)];
}
if (sqlite3_column_text(stmt,2 ) != NULL) {
deviceUDN = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 2)];
}
if (sqlite3_column_text(stmt,3 ) != NULL) {
friendlyName = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 3)];
}
if (sqlite3_column_text(stmt,4 ) != NULL) {
int i = sqlite3_column_int(stmt, 4);
time = [NSDate dateWithTimeIntervalSince1970:i];
// time = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 4)];
}
if (sqlite3_column_text(stmt,5 ) != NULL) {
deviceDesc = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 5)];
}
di.deviceType=deviceType;
di.deviceUDN=deviceUDN;
di.friendlyName=friendlyName;
di.time = time;
di.deviceDesc =deviceDesc;
di.c_id = c_id;
[dis addObject:di];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return dis ;
}
- (NSMutableArray*)getHistoryRecordWithTHistoryRecordByAccount:(NSString* )account routerjid:(NSString *)routerjid
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
const char* sql = "select * from t_history_record where c_user = ? and c_router = ? order by c_history_time desc";//查询语句
sqlite3_stmt* stmt;
if (sqlite3_prepare_v2(db, sql, -1, &stmt, nil)==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1,[account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2,[routerjid UTF8String], -1, NULL);
}else{
return nil;
}
NSMutableArray *dis=[[[NSMutableArray alloc]initWithCapacity:5]autorelease];
while ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
DescInfo* di = [[[DescInfo alloc]init]autorelease];
NSString* deviceType = nil;
NSString* friendlyName= nil;
NSString* deviceUDN= nil;
NSString* deviceDesc= nil;
NSDate* time= nil;
int c_id = 0;
if (sqlite3_column_text(stmt, 0) != NULL) {
c_id = sqlite3_column_int(stmt, 0);
}
if (sqlite3_column_text(stmt, 1) != NULL) {
deviceType = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 1)];
}
if (sqlite3_column_text(stmt,2 ) != NULL) {
deviceUDN = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 2)];
}
if (sqlite3_column_text(stmt,3 ) != NULL) {
friendlyName = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 3)];
}
if (sqlite3_column_text(stmt,4 ) != NULL) {
int i = sqlite3_column_int(stmt, 4);
time = [NSDate dateWithTimeIntervalSince1970:i];
// time = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 4)];
}
if (sqlite3_column_text(stmt,5 ) != NULL) {
deviceDesc = [NSString stringWithUTF8String:(char*)sqlite3_column_text(stmt, 5)];
}
di.deviceType=deviceType;
di.deviceUDN=deviceUDN;
di.friendlyName=friendlyName;
di.time = time;
di.deviceDesc =deviceDesc;
di.c_id = c_id;
[dis addObject:di];
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return dis ;
}
- (BOOL)deleteHistoryWithTHistoryRecordByDeviceType:(NSString *)deviceType account:(NSString* )account routerjid:(NSString *)routerjid
{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
NSString* sql = [NSString stringWithFormat:@"delete from t_history_record where c_deviceType = ? and c_user = ? and c_router = ?"];
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [deviceType UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3, [routerjid UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
- (BOOL)deleteHistoryWithTHistoryRecordById:(int)c_id account:(NSString* )account routerjid:(NSString *)routerjid
{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
NSString* sql = [NSString stringWithFormat:@"delete from t_history_record where c_id = ? and c_user = ? and c_router = ?"];
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
// sqlite3_bind_text(stmt, 1, [c_id UTF8String], -1, NULL);
sqlite3_bind_int(stmt, 1, c_id);
sqlite3_bind_text(stmt, 2, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3, [routerjid UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
//update the count of history record not read
-(BOOL)updateHistoryCountNotReadWithHistoryRecordByDeviceType:(NSString *)deviceType account:(NSString* )account routerjid:(NSString *)routerjid
{
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
NSString * sql = [NSString stringWithFormat:@"update t_history_record set c_has_read = 1 where c_deviceType = ? and c_user = ? and c_router = ?"];//查询语句
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1, [deviceType UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 3, [routerjid UTF8String], -1, NULL);
}else{
return nil;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
-(int)getHistoryCountNotReadWithHistoryRecordByAccount:(NSString *)account routerjid:(NSString *)routerjid
{
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String] , &db)){
return nil;
}
NSString * sql = [NSString stringWithFormat:@"select count (*) from t_history_record where c_has_read = 0 and c_user = ? and c_router = ?"];//查询语句
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备
sqlite3_bind_text(stmt, 1, [account UTF8String], -1, NULL);
sqlite3_bind_text(stmt, 2, [routerjid UTF8String], -1, NULL);
}else{
return nil;
}
int count=0;
if ( SQLITE_ROW == sqlite3_step(stmt) ){//执行
count=sqlite3_column_int(stmt, 0);
}
sqlite3_finalize(stmt);
sqlite3_close(db);
return count ;
}
#pragma mark manage normal tables
- (BOOL)deleteItemWithTable:(NSString*)table_ ByKey:(NSString*)key_ {
int ret = 0;
if (SQLITE_OK != sqlite3_open([[self getFilePath] UTF8String], &db)){//打开数据库
return NO;
}
NSString* sql= [NSString stringWithFormat:@"delete from %@ where c_account = ?",table_];
sqlite3_stmt* stmt;//
int result =sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil);
printf("%s\n",sqlite3_errmsg(db));
if (result==SQLITE_OK) {//准备语句
sqlite3_bind_text(stmt, 1, [key_ UTF8String], -1, NULL);
}else{
return NO;
}
if (SQLITE_DONE == (ret = sqlite3_step(stmt))) {//执行查询
sqlite3_finalize(stmt);
sqlite3_close(db);
return YES;
}else{
return NO;
}
}
时间： 2024-11-14 13:29:11