FMDB数据库的简单实用

引入和FMDB第三方类库，  demo地址：http://pan.baidu.com/s/1c0pbfxA

#define dataBasePath [[(NSSearchPathForDirectoriesInDomains(NSDocumentDirectory,NSUserDomainMask,YES)) lastObject]stringByAppendingPathComponent:dataBaseName]
#define dataBaseName @"MyDatabase.db"
#import "ViewController.h"
#import "FMDatabase.h"
#import "FMDatabaseAdditions.h"
#import "FMDatabaseQueue.h"


#import "MYDataBase.h"
@interface ViewController ()

@end

@implementation ViewController

- (void)viewDidLoad
{
    [super viewDidLoad];
    // Do any additional setup after loading the view, typically from a nib.
    FMDatabase *db = [FMDatabase databaseWithPath:dataBasePath];
    if (![db open]) {
        NSLog(@"no");
        return;
    }NSLog(@"111");
    //建立新表
    [db executeUpdate:@"CREATE TABLE PersonList (Name text, Age integer, Sex integer, Phone text, Address text, Photo blob)"];
    
    //插入一条数据
    [db executeUpdate:@"INSERT INTO PersonList (Name, Age, Sex, Phone, Address, Photo) VALUES (?,?,?,?,?,?)",
     @"Jone", [NSNumber numberWithInt:20], [NSNumber numberWithInt:0], @"091234567", @"Taiwan, R.O.C", nil];
    //更新数据
    [db executeUpdate:@"UPDATE PersonList SET Age = ? WHERE Name = ?",[NSNumber numberWithInt:30],@"John"];
    
    
   //取数据
    //返回数据库中第一条满足条件的结果
    NSString *aa=[db stringForQuery:@"SELECT Name FROM User WHERE Name = ?",@"John"];
    
    //fan返回满足条件的全部结果
   // FMResultSet *rs = [db executeQuery:@"SELECT Name, Age FROM PersonList"];
    //
    FMResultSet *rs = [db executeQuery:@"SELECT * FROM PersonList"];
    
    while ([rs next]) {
        
        NSString *name = [rs stringForColumn:@"Name"];
        
        int age = [rs intForColumn:@"Age"];
        NSLog(@"name=%@,age = %d",name,age);
        
    }
    
    [rs close];
    
    
    
    //快速读取一个row的一个数据
    //找地址
    
    NSString *address = [db stringForQuery:@"SELECT Address FROM PersonList WHERE Name = ?",@"John"];
    NSLog(@"address=%@",address);
                         //找年齡
                    
                         int age = [db intForQuery:@"SELECT Age FROM PersonList WHERE Name = ?",@"John"];
    
    NSLog(@"age2 = %d",age);
    
    
    //可以多个参数穿进去
    NSDictionary *argsDict = [NSDictionary dictionaryWithObjectsAndKeys:@"donghongqiang", @"name",@"14",@"Age",@"dezhou",@"Address", nil];
    [db executeUpdate:@"INSERT INTO PersonList (Name,Age,Address) VALUES (:name,:Age,:Address)" withParameterDictionary:argsDict];

    
    NSString *address2 = [db stringForQuery:@"SELECT Address FROM PersonList WHERE Name = ?",@"donghongqiang"];
    NSLog(@"address2=%@",address2);
    
    
}

对一些多线程操作的情况，要使用FMDatabaseQueue来操作，防止多线程对一个数据库操作发生错误

-(void)FMDbatabasequeue

{

    

    // 创建，最好放在一个单例的类中

    FMDatabaseQueue *queue = [FMDatabaseQueuedatabaseQueueWithPath:dataBasePath];

    

    // 使用

    [queue inDatabase:^(FMDatabase *db) {

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:1]];

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:2]];

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:3]];

        

        FMResultSet *rs = [db executeQuery:@"select * from foo"];

        while ([rs next]) {

            // …

        }

    }];

    

    // 如果要支持事务

    [queue inTransaction:^(FMDatabase *db, BOOL *rollback) {

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:1]];

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:2]];

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:3]];

        

//        if (whoopsSomethingWrongHappened) {

//            *rollback = YES;

//            return;

//        }

        // etc…

        [db executeUpdate:@"INSERT INTO myTable VALUES (?)", [NSNumbernumberWithInt:4]];

    }];

    

    

    

    

    

    [queue close];

}

 

可以封装成单例的类，来进行操作，

//  Created by apple on 14-4-28.
//  Copyright (c) 2014年 apple. All rights reserved.
//
#define dataBasePath [[(NSSearchPathForDirectoriesInDomains(NSDocumentDirectory,NSUserDomainMask,YES)) lastObject]stringByAppendingPathComponent:dataBaseName]
#define dataBaseName @"MyDatabase.db"

#import <Foundation/Foundation.h>
#import "FMDatabaseQueue.h"
#import "Pins.h"
#import "FMDatabaseAdditions.h"
#import "FMDatabase.h"
@interface MYDataBase : NSObject
{
    
}
@property(nonatomic,retain)FMDatabaseQueue *dbQueue;

+(MYDataBase*)sharedInstance;
-(Pins*)rsToPins:(FMResultSet*)rs;
- (void)addPins:(Pins*)pin;
- (NSArray *)getPins;
@end

//
//  MYDataBase.m
//  TextFMDB
//
//  Created by apple on 14-4-28.
//  Copyright (c) 2014年 apple. All rights reserved.
//

#import "MYDataBase.h"
static MYDataBase *mydatabase = nil;
@implementation MYDataBase

- (id)init
{
    
    self = [super init];
    if (self)
    {
       // self.dbFile = [DbFileManager dbFilePath];
        self.dbQueue = [FMDatabaseQueue databaseQueueWithPath:dataBasePath];
        
        
    }
    return  self;
}
+(MYDataBase*)sharedInstance{
    
    
    @synchronized(self)
    {
        if (mydatabase == nil)
            mydatabase = [[MYDataBase alloc] init];
    }
    return mydatabase;
}

//huoq获取pin
-(Pins*)rsToPins:(FMResultSet*)rs
{
    Pins *pin = [[Pins alloc] init] ;
//    user.ID = [rs intForColumn:@"_id"];
//    user.name = [rs stringForColumn:@"name"];
//    user.password = [rs  stringForColumn:@"password"];
    return pin;
    
}

- (void)addPins:(Pins*)pin
{
    [self.dbQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
        [db open];
//        NSString *sql = @"insert into tbl_user(name, password) values (?, ?)";
//        [db executeUpdate:sql,user.name, user.password];
        [db close];
    }];
}

- (NSArray *)getPins;
{
    __block NSMutableArray *users = [[NSMutableArray alloc] init];
    [self.dbQueue inDatabase:^(FMDatabase *db)   {
        [db open];
        NSString *sql = @"select * from tbl_user ";
        FMResultSet *rs = [db executeQuery:sql];
        while ([rs next])
        {
            [users addObject:[self rsToPins :rs]];
        }
        [db close];
    }];
    return users;
}

@end

其中的pins类

#import <Foundation/Foundation.h>

@interface Pins : NSObject
{
    
}
@property(nonatomic,assign)int ID;
@property(nonatomic,retain)NSString *name;
@property(nonatomic,retain)NSString *address;
@property(nonatomic,retain)NSData *imagedata;

//+(Pins*)sharedInstance;

@end

#import "Pins.h"

@implementation Pins
@synthesize ID = _ID,name = _name,address = _address,imagedata = _imagedata;



@end