//
//  DDDBManager.h
//  YZDoctors
//
//  Created by lishengshu on 15-7-29.
//  Copyright (c) 2015年 李胜书. All rights reserved.
//

#import "DDDBSearchHisManager.h"
#import "DDNSObject+Ext.h"
#import <objc/runtime.h>

#import "MJExtension.h"

#define DDWS(weakSelf)  __weak __typeof(&*self)weakSelf = self;
#define DDSS(strongSelf)  __strong __typeof(weakSelf)strongSelf = weakSelf;

@interface DDDBSearchHisManager ()

{
    NSString *dbPath;///< 数据库存储路径
    NSString *dbCName;///< 当前db的名字
    FMDatabaseQueue *dbQueue;///< 使用多线程操作
}

@property (nonatomic,weak) id<DDDBManagerDelegate> delegate;

@end;

@implementation DDDBSearchHisManager

struct {
    unsigned int tableReadyResult:1;
    unsigned int tableInsertResult:1;
    unsigned int tableSearchResult:1;
    unsigned int tableUpdateResult:1;
    unsigned int tableDeleteResult:1;
    unsigned int dbCloseResult:1;
} delegateRespondsTo;

+ (DDDBSearchHisManager *)ShareInstance{
    static DDDBSearchHisManager *sharedDBManagerInstance = nil;
    static dispatch_once_t predicate;
    dispatch_once(&predicate, ^{
        sharedDBManagerInstance = [[self alloc] init];
    });
    return sharedDBManagerInstance;
}
#pragma mark - 创建并打开数据库------------------------|*|*|*|*|*|
- (BOOL)creatDatabase:(NSString *)dbName {
    NSString *docsdir = [NSSearchPathForDirectoriesInDomains( NSDocumentDirectory, NSUserDomainMask, YES) lastObject];
    dbPath = [docsdir stringByAppendingPathComponent:[NSString stringWithFormat:@"%@.sqlite",dbName]];
    dbCName = dbName;
    self.searchHisDB = [FMDatabase databaseWithPath:dbPath];
    //为数据库设置缓存，提高查询效率
    [self.searchHisDB setShouldCacheStatements:YES];
    return [self.searchHisDB open];
}

- (BOOL)isDBReady {
    if(!self.searchHisDB) {
        return NO;
    }
    if (![self.searchHisDB open]) {
        return NO;
    }
    return YES;
}
#pragma mark - 判断表是否存在,不存在则创建表------------------------|*|*|*|*|*|
- (BOOL)isTableExist:(NSString *)tName
             tKeyArr:(NSArray *)keyArr {
    if (![self isDBReady])
        return NO;
    if(![self.searchHisDB tableExists:tName]) {
        __block NSString *tempSql = @"(ddkey INTEGER PRIMARY KEY AUTOINCREMENT";
        [keyArr enumerateObjectsUsingBlock:^(NSString *obj, NSUInteger idx, BOOL * _Nonnull stop) {
            if(idx < keyArr.count - 1) {
                tempSql = [NSString stringWithFormat:@"%@,%@ TEXT",tempSql,obj];
            }else {
                tempSql = [NSString stringWithFormat:@"%@,%@ TEXT)",tempSql,obj];
            }
        }];
        NSString *sql = [NSString stringWithFormat:@"create table %@%@",tName,tempSql];
        return [self.searchHisDB executeUpdate:sql];
    }else {
        return YES;
    }
}

- (BOOL)isTableExist:(NSString *)tName
              tModel:(Class)tableClass {
    NSArray *proArr = [self getAllPropertiesNameArr:tableClass];
    return [self isTableExist:tName
                      tKeyArr:proArr];
}

- (void)isTableExistQueue:(NSString *)tName
                  tKeyArr:(NSArray *)keyArr {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if (db && [db open]) {
            if(![db tableExists:tName]) {
                __block NSString *tempSql = @"(ddkey INTEGER PRIMARY KEY AUTOINCREMENT";
                [keyArr enumerateObjectsUsingBlock:^(NSString *obj, NSUInteger idx, BOOL * _Nonnull stop) {
                    if(idx < keyArr.count - 1) {
                        tempSql = [NSString stringWithFormat:@"%@,%@ TEXT",tempSql,obj];
                    }else {
                        tempSql = [NSString stringWithFormat:@"%@,%@ TEXT)",tempSql,obj];
                    }
                }];
                NSString *sql = [NSString stringWithFormat:@"create table %@%@",tName,tempSql];
                BOOL result = [db executeUpdate:sql];
                if (delegateRespondsTo.tableReadyResult) {
                    [weakSelf.delegate tableReadyResult:result
                                                  tName:tName];
                }
            }else {
                if (delegateRespondsTo.tableReadyResult) {
                    [weakSelf.delegate tableReadyResult:YES
                                                  tName:tName];
                }
            }
        }else {
            if (delegateRespondsTo.tableReadyResult) {
                [weakSelf.delegate tableReadyResult:NO
                                              tName:tName];
            }
        }
    }];
}

- (void)isTableExistQueue:(NSString *)tName
                  tKeyArr:(NSArray *)keyArr
                   result:(void(^)(BOOL result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if (db && [db open]) {
            if(![db tableExists:tName]) {
                __block NSString *tempSql = @"(ddkey INTEGER PRIMARY KEY AUTOINCREMENT";
                [keyArr enumerateObjectsUsingBlock:^(NSString *obj, NSUInteger idx, BOOL * _Nonnull stop) {
                    if(idx < keyArr.count - 1) {
                        tempSql = [NSString stringWithFormat:@"%@,%@ TEXT",tempSql,obj];
                    }else {
                        tempSql = [NSString stringWithFormat:@"%@,%@ TEXT)",tempSql,obj];
                    }
                }];
                NSString *sql = [NSString stringWithFormat:@"create table %@%@",tName,tempSql];
                BOOL result = [db executeUpdate:sql];
                if (resultBlock) {
                    resultBlock(result);
                }
            }else {
                if (resultBlock) {
                    resultBlock(YES);
                }
            }
        }else {
            if (resultBlock) {
                resultBlock(NO);
            }
        }
    }];
}

- (void)isTableExistQueue:(NSString *)tName
                   tModel:(Class)tableClass {
    NSArray *proArr = [self getAllPropertiesNameArr:tableClass];
    [self isTableExistQueue:tName
                    tKeyArr:proArr];
}

- (void)isTableExistQueue:(NSString *)tName
                   tModel:(Class)tableClass
                   result:(void(^)(BOOL result))resultBlock {
    NSArray *proArr = [self getAllPropertiesNameArr:tableClass];
    [self isTableExistQueue:tName
                    tKeyArr:proArr
                     result:resultBlock];
}
#pragma mark - 插入列表 或者更新------------------------|*|*|*|*|*|
- (BOOL)insertTableObj:(NSString *)tName
               dataDic:(NSDictionary *)dataDic {
    NSArray *keyArr = [dataDic allKeys];
    if ([self.searchHisDB tableExists:tName]) {
        if (keyArr.count > 0) {
            FMResultSet *searchResult = [self searchOne:tName
                                              searchDic:dataDic];
            if (![searchResult next]) {
                NSString *insertsql = [self insertSQL:tName
                                              dataDic:dataDic];
                return [self.searchHisDB executeUpdate:insertsql];
            }
        }
    }
    return NO;
}

- (BOOL)insertTableObj:(NSString *)tName
             dataModel:(NSObject *)dataClass {
    return [self insertTableObj:tName
                        dataDic:dataClass.mj_keyValues];
}

- (BOOL)directInsertTableObj:(NSString *)tName
                     dataDic:(NSDictionary *)dataDic {
    NSArray *keyArr = [dataDic allKeys];
    if ([self.searchHisDB tableExists:tName]) {
        if (keyArr.count > 0) {
            NSString *insertsql = [self insertSQL:tName
                                          dataDic:dataDic];
            return [self.searchHisDB executeUpdate:insertsql];
        }
    }
    return NO;
}

- (BOOL)directInsertTableObj:(NSString *)tName
                   dataModel:(NSObject *)dataClass {
    return [self directInsertTableObj:tName
                              dataDic:dataClass.mj_keyValues];
}

- (void)directInsertTableObjQueue:(NSString *)tName
                          dataDic:(NSDictionary *)dataDic {
    NSArray *keyArr = [dataDic allKeys];
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if ([db tableExists:tName]) {
            if (keyArr.count > 0) {
                DDSS(strongSelf)
                NSString *insertsql = [strongSelf insertSQL:tName
                                                    dataDic:dataDic];
                if (delegateRespondsTo.tableInsertResult) {
                    [weakSelf.delegate tableInsertResult:[db executeUpdate:insertsql]
                                                   tName:tName
                                                 dataDic:dataDic];
                }else {
                    [db executeUpdate:insertsql];
                }
            }else {
                if (delegateRespondsTo.tableInsertResult) {
                    [weakSelf.delegate tableInsertResult:NO
                                                   tName:tName
                                                 dataDic:dataDic];
                }
            }
        }else {
            if (delegateRespondsTo.tableInsertResult) {
                [weakSelf.delegate tableInsertResult:NO
                                               tName:tName
                                             dataDic:dataDic];
            }
        }
    }];
}

- (void)directInsertTableObjQueue:(NSString *)tName
                          dataDic:(NSDictionary *)dataDic
                           result:(void(^)(BOOL result))resultBlock {
    NSArray *keyArr = [dataDic allKeys];
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if ([db tableExists:tName]) {
            if (keyArr.count > 0) {
                DDSS(strongSelf)
                NSString *insertsql = [strongSelf insertSQL:tName
                                                    dataDic:dataDic];
                BOOL result = [db executeUpdate:insertsql];
                if (resultBlock) {
                    resultBlock(result);
                }
            }else {
                if (resultBlock) {
                    resultBlock(NO);
                }
            }
        }else {
            if (resultBlock) {
                resultBlock(NO);
            }
        }
    }];
}

- (void)directInsertTableObjQueue:(NSString *)tName
                        dataModel:(NSObject *)dataClass {
    [self directInsertTableObjQueue:tName
                            dataDic:dataClass.mj_keyValues];
}

- (void)directInsertTableObjQueue:(NSString *)tName
                        dataModel:(NSObject *)dataClass
                           result:(void(^)(BOOL result))resultBlock {
    [self directInsertTableObjQueue:tName
                            dataDic:dataClass.mj_keyValues
                             result:resultBlock];
}

- (void)insertTableObjQueue:(NSString *)tName
                    dataDic:(NSDictionary *)dataDic {
    NSArray *keyArr = [dataDic allKeys];
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if ([db tableExists:tName]) {
            if (keyArr.count > 0) {
                FMResultSet *searchResult;
                DDSS(strongSelf)
                NSString *searchsql = [strongSelf searchSQL:tName
                                                  searchDic:dataDic];
                if ([db tableExists:tName]) {
                    searchResult = [db executeQuery:searchsql];
                }
                if (![searchResult next]) {
                    NSString *insertsql = [strongSelf insertSQL:tName
                                                        dataDic:dataDic];
                    if (delegateRespondsTo.tableInsertResult) {
                        [weakSelf.delegate tableInsertResult:[db executeUpdate:insertsql]
                                                       tName:tName
                                                     dataDic:dataDic];
                    }else {
                        [db executeUpdate:insertsql];
                    }
                }else {
                    if (delegateRespondsTo.tableInsertResult) {
                        [weakSelf.delegate tableInsertResult:NO
                                                       tName:tName
                                                     dataDic:dataDic];
                    }
                }
            }else {
                if (delegateRespondsTo.tableInsertResult) {
                    [weakSelf.delegate tableInsertResult:NO
                                                   tName:tName
                                                 dataDic:dataDic];
                }
            }
        }else {
            if (delegateRespondsTo.tableInsertResult) {
                [weakSelf.delegate tableInsertResult:NO
                                               tName:tName
                                             dataDic:dataDic];
            }
        }
    }];
}

- (void)insertTableObjQueue:(NSString *)tName
                    dataDic:(NSDictionary *)dataDic
                     result:(void(^)(BOOL result))resultBlock {
    NSArray *keyArr = [dataDic allKeys];
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if ([db tableExists:tName]) {
            if (keyArr.count > 0) {
                FMResultSet *searchResult;
                DDSS(strongSelf)
                NSString *searchsql = [strongSelf searchSQL:tName
                                                  searchDic:dataDic];
                if ([db tableExists:tName]) {
                    searchResult = [db executeQuery:searchsql];
                }
                if (![searchResult next]) {
                    NSString *insertsql = [strongSelf insertSQL:tName
                                                        dataDic:dataDic];
                    BOOL result = [db executeUpdate:insertsql];
                    if (resultBlock) {
                        resultBlock(result);
                    }
                }else {
                    if (resultBlock) {
                        resultBlock(NO);
                    }
                }
            }else {
                if (resultBlock) {
                    resultBlock(NO);
                }
            }
        }else {
            if (resultBlock) {
                resultBlock(NO);
            }
        }
    }];
}

- (void)insertTableObjQueue:(NSString *)tName
                  dataModel:(NSObject *)dataClass {
    [self insertTableObjQueue:tName
                      dataDic:dataClass.mj_keyValues];
}

- (void)insertTableObjQueue:(NSString *)tName
                  dataModel:(NSObject *)dataClass
                     result:(void(^)(BOOL result))resultBlock {
    [self insertTableObjQueue:tName
                      dataDic:dataClass.mj_keyValues
                       result:resultBlock];
}
#pragma mark - 查询数据------------------------|*|*|*|*|*|
//while ([messWithNumber next]) {
//obj.mycontent = [messWithNumber stringForColumn:@"key"];
- (FMResultSet *)searchOne:(NSString *)tName
                 searchDic:(NSDictionary *)searchDic {
    FMResultSet *messWithNumber;
    NSString *searchsql = [self searchSQL:tName
                                searchDic:searchDic];
    if ([self.searchHisDB tableExists:tName]) {
        messWithNumber = [self.searchHisDB executeQuery:searchsql];
    }
    return messWithNumber;
}

- (FMResultSet *)searchOne:(NSString *)tName
               searchModel:(NSObject *)searchClass {
    return [self searchOne:tName
                 searchDic:searchClass.mj_keyValues];
}

- (void)searchOneQueue:(NSString *)tName
             searchDic:(NSDictionary *)searchDic {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        DDSS(strongSelf)
        NSString *searchsql = [strongSelf searchSQL:tName
                                          searchDic:searchDic];
        if ([db tableExists:tName]) {
            messWithNumber = [db executeQuery:searchsql];
        }
        if (delegateRespondsTo.tableSearchResult) {
            [weakSelf.delegate tableSearchResult:messWithNumber
                                           tName:tName
                                         dataDic:searchDic];
        }
    }];
}

- (void)searchOneQueue:(NSString *)tName
             searchDic:(NSDictionary *)searchDic
                result:(void(^)(id result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        DDSS(strongSelf)
        NSString *searchsql = [strongSelf searchSQL:tName
                                          searchDic:searchDic];
        if ([db tableExists:tName]) {
            messWithNumber = [db executeQuery:searchsql];
        }
        if (resultBlock) {
            resultBlock(messWithNumber);
        }
    }];
}

- (void)searchOneQueue:(NSString *)tName
           searchModel:(NSObject *)searchClass {
    [self searchOneQueue:tName
               searchDic:searchClass.mj_keyValues];
}

- (void)searchOneQueue:(NSString *)tName
           searchModel:(NSObject *)searchClass
                result:(void (^)(id))resultBlock{
    [self searchOneQueue:tName
               searchDic:searchClass.mj_keyValues
                  result:resultBlock];
}

- (FMResultSet *)searchLastNumber:(NSString *)tableName
                           number:(long)number {
    FMResultSet *messWithNumber;
    NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@ order by ddkey DESC limit 0,%ld",tableName,number];
    if ([self.searchHisDB tableExists:tableName]) {
        messWithNumber = [self.searchHisDB executeQuery:searchsql];
    }
    return messWithNumber;
}

- (void)searchLastNumberQueue:(NSString *)tName
                       number:(long)number {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@ order by ddkey DESC limit 0,%ld",tName,number];
        if ([db tableExists:tName]) {
            messWithNumber = [db executeQuery:searchsql];
        }
        if (delegateRespondsTo.tableSearchResult) {
            [weakSelf.delegate tableSearchResult:messWithNumber
                                           tName:nil
                                         dataDic:nil];
        }
    }];
}

- (void)searchLastNumberQueue:(NSString *)tName
                       number:(long)number
                       result:(void(^)(id result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@ order by ddkey DESC limit 0,%ld",tName,number];
        if ([db tableExists:tName]) {
            messWithNumber = [db executeQuery:searchsql];
        }
        if (resultBlock) {
            resultBlock(messWithNumber);
        }
    }];
}

- (FMResultSet *)searchAll:(NSString *)tName {
    FMResultSet *messWithNumber;
    NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@",tName];
    if ([self.searchHisDB tableExists:tName]) {
        messWithNumber = [self.searchHisDB executeQuery:searchsql];
    }
    return messWithNumber;
}

- (void)searchAllQueue:(NSString *)tName {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@",tName];
        if ([self.searchHisDB tableExists:tName]) {
            messWithNumber = [self.searchHisDB executeQuery:searchsql];
        }
        if (delegateRespondsTo.tableSearchResult) {
            [weakSelf.delegate tableSearchResult:messWithNumber
                                           tName:nil
                                         dataDic:nil];
        }
    }];
}

- (void)searchAllQueue:(NSString *)tName
                result:(void(^)(FMResultSet *result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        FMResultSet *messWithNumber;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT * FROM %@",tName];
        if ([weakSelf.searchHisDB tableExists:tName]) {
            messWithNumber = [weakSelf.searchHisDB executeQuery:searchsql];
        }
        if (resultBlock) {
            resultBlock(messWithNumber);
        }
    }];
}

- (NSMutableArray *)searchAllTableName {
    NSMutableArray *tableMessName = [NSMutableArray array];
    FMResultSet  *tableNameSet;
    NSString *searchsql = [NSString stringWithFormat:@"SELECT NAME FROM sqlite_master WHERE type='table' order by name"];
    tableNameSet = [self.searchHisDB executeQuery:searchsql];
    while ([tableNameSet next]) {
        if (![[tableNameSet stringForColumn:@"name"] isEqualToString:@"sqlite_sequence"]) {
            NSString *tableStringName = [tableNameSet stringForColumn:@"name"];
            [tableMessName addObject:tableStringName];
        }
    }
    return tableMessName;
}

- (void)searchAllTableNameQueue {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        NSMutableArray *tableMessName = [NSMutableArray array];
        FMResultSet  *tableNameSet;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT NAME FROM sqlite_master WHERE type='table' order by name"];
        tableNameSet = [db executeQuery:searchsql];
        while ([tableNameSet next]) {
            if (![[tableNameSet stringForColumn:@"name"] isEqualToString:@"sqlite_sequence"]) {
                NSString *tableStringName = [tableNameSet stringForColumn:@"name"];
                [tableMessName addObject:tableStringName];
            }
        }
        if (delegateRespondsTo.tableSearchResult) {
            [weakSelf.delegate tableSearchResult:tableMessName
                                           tName:nil
                                         dataDic:nil];
        }
    }];
}

- (void)searchAllTableNameQueue:(void(^)(NSMutableArray *result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        NSMutableArray *tableMessName = [NSMutableArray array];
        FMResultSet  *tableNameSet;
        NSString *searchsql = [NSString stringWithFormat:@"SELECT NAME FROM sqlite_master WHERE type='table' order by name"];
        tableNameSet = [db executeQuery:searchsql];
        while ([tableNameSet next]) {
            if (![[tableNameSet stringForColumn:@"name"] isEqualToString:@"sqlite_sequence"]) {
                NSString *tableStringName = [tableNameSet stringForColumn:@"name"];
                [tableMessName addObject:tableStringName];
            }
        }
        if (resultBlock) {
            resultBlock(tableMessName);
        }
    }];
}
#pragma mark - 更新表------------------------|*|*|*|*|*|
- (BOOL)updateTableObj:(NSString *)tName
             searchDic:(NSDictionary *)searchDic
               dataDic:(NSDictionary *)dataDic {
    BOOL updateResult = NO;
    NSString *updateSql = [self updateSQL:tName
                                searchDic:searchDic
                                  dataDic:dataDic];
    if ([self.searchHisDB tableExists:tName]) {
        updateResult = [self.searchHisDB executeUpdate:updateSql];
    }
    return updateResult;
}

- (BOOL)updateTableObj:(NSString *)tName
           searchModel:(NSObject *)searchClass
             dataModel:(NSObject *)dataClass {
    return [self updateTableObj:tName
                      searchDic:searchClass.mj_keyValues
                        dataDic:dataClass.mj_keyValues];
}

- (void)updateTableObjQueue:(NSString *)tName
                  searchDic:(NSDictionary *)searchDic
                    dataDic:(NSDictionary *)dataDic {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        DDSS(strongSelf)
        NSString *updateSql = [strongSelf updateSQL:tName
                                          searchDic:searchDic
                                            dataDic:dataDic];
        if ([db tableExists:tName]) {
            if (delegateRespondsTo.tableUpdateResult) {
                [weakSelf.delegate tableUpdateResult:[db executeUpdate:updateSql]
                                               tName:tName
                                              search:searchDic
                                             dataDic:dataDic];
            }else {
                [db executeUpdate:updateSql];
            }
        }else {
            if (delegateRespondsTo.tableUpdateResult) {
                [weakSelf.delegate tableUpdateResult:NO
                                               tName:tName
                                              search:searchDic
                                             dataDic:dataDic];
            }
        }
    }];
}

- (void)updateTableObjQueue:(NSString *)tName
                  searchDic:(NSDictionary *)searchDic
                    dataDic:(NSDictionary *)dataDic
                     result:(void(^)(BOOL result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        DDSS(strongSelf)
        NSString *updateSql = [strongSelf updateSQL:tName
                                          searchDic:searchDic
                                            dataDic:dataDic];
        if ([db tableExists:tName]) {
            BOOL result = [db executeUpdate:updateSql];
            if (resultBlock) {
                resultBlock(result);
            }
        } else {
            if (resultBlock) {
                resultBlock(NO);
            }
        }
    }];
}

- (void)updateTableObjQueue:(NSString *)tName
                searchModel:(NSObject *)searchClass
                  dataModel:(NSObject *)dataClass {
    [self updateTableObjQueue:tName
                    searchDic:searchClass.mj_keyValues
                      dataDic:dataClass.mj_keyValues];
}

- (void)updateTableObjQueue:(NSString *)tName
                searchModel:(NSObject *)searchClass
                  dataModel:(NSObject *)dataClass
                     result:(void(^)(BOOL result))resultBlock {
    [self updateTableObjQueue:tName
                    searchDic:searchClass.mj_keyValues
                      dataDic:dataClass.mj_keyValues
                       result:resultBlock];
}
#pragma mark - 删除表------------------------|*|*|*|*|*|
- (BOOL)deleteTable:(NSString *)tName {
    NSString *sqlstr = [NSString stringWithFormat:@"DROP TABLE %@", tName];
    if (![self.searchHisDB executeUpdate:sqlstr]) {
        return NO;
    }
    return YES;
}

- (void)deleteTableQueue:(NSString *)tName {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        NSString *sqlstr = [NSString stringWithFormat:@"DROP TABLE %@", tName];
        if (delegateRespondsTo.tableDeleteResult) {
            [weakSelf.delegate tableDeleteResult:[db executeUpdate:sqlstr]
                                           tName:tName];
        }else {
            [db executeUpdate:sqlstr];
        }
    }];
}

- (void)deleteTableQueue:(NSString *)tName
                  result:(void(^)(BOOL result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        NSString *sqlstr = [NSString stringWithFormat:@"DROP TABLE %@", tName];
        BOOL result = [db executeUpdate:sqlstr];
        if (resultBlock) {
            resultBlock(result);
        }
    }];
}
#pragma mark - 根据sqlKey删除数据------------------------|*|*|*|*|*|
- (BOOL)deleTableOjb:(NSString *)tName
           deleteDic:(NSDictionary *)deleteDic {
    if ([self.searchHisDB tableExists:tName]) {
        NSString *deleteSQL = [self deleteSQL:tName
                                    deleteDic:deleteDic];
        return [self.searchHisDB executeUpdate:deleteSQL];
    }
    return NO;
}

- (void)deleTableOjbQueue:(NSString *)tName
                deleteDic:(NSDictionary *)deleteDic {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        DDSS(strongSelf)
        NSString *deleteSQL = [strongSelf deleteSQL:tName
                                          deleteDic:deleteDic];
        if (delegateRespondsTo.tableDeleteResult) {
            [weakSelf.delegate tableDeleteResult:[db executeUpdate:deleteSQL]
                                           tName:tName];
        }else {
            [db executeUpdate:deleteSQL];
        }
    }];
}

- (void)deleTableOjbQueue:(NSString *)tName
                deleteDic:(NSDictionary *)deleteDic
                   result:(void(^)(BOOL result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        DDSS(strongSelf)
        NSString *deleteSQL = [strongSelf deleteSQL:tName
                                          deleteDic:deleteDic];
        BOOL result = [db executeUpdate:deleteSQL];
        if (resultBlock) {
            resultBlock(result);
        }
    }];
}
#pragma mark - 关闭数据库------------------------|*|*|*|*|*|
- (BOOL)closeDB {
    return [self.searchHisDB close];
}

- (void)closeDBQueue {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    DDWS(weakSelf)
    NSString *dbName = dbCName;
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        if (delegateRespondsTo.dbCloseResult) {
            [weakSelf.delegate dbCloseResult:[db close]
                                      dbName:dbName];
        }else {
            [db close];
        }
    }];
}

- (void)closeDBQueue:(void(^)(BOOL result))resultBlock {
    if (!dbQueue) {
        dbQueue = [[FMDatabaseQueue alloc]initWithPath:dbPath];
    }
    [dbQueue inTransaction:^(FMDatabase * _Nonnull db, BOOL * _Nonnull rollback) {
        BOOL result = [db close];
        if (resultBlock) {
            resultBlock(result);
        }
    }];
}
#pragma mark - lazy loading统一检查是否响应delegate
- (void)setDelegate:(id<DDDBManagerDelegate>)delegate {
    if (_delegate != delegate) {
        _delegate = delegate;
        delegateRespondsTo.tableReadyResult = [delegate respondsToSelector:@selector(tableReadyResult:tName:)];
        delegateRespondsTo.tableDeleteResult = [delegate respondsToSelector:@selector(tableDeleteResult:tName:)];
        delegateRespondsTo.tableInsertResult = [delegate respondsToSelector:@selector(tableInsertResult:tName:dataDic:)];
        delegateRespondsTo.tableSearchResult = [delegate respondsToSelector:@selector(tableSearchResult:tName:dataDic:)];
        delegateRespondsTo.tableUpdateResult = [delegate respondsToSelector:@selector(tableUpdateResult:tName:search:dataDic:)];
        delegateRespondsTo.dbCloseResult = [delegate respondsToSelector:@selector(dbCloseResult:dbName:)];
    }
}
#pragma mark - support methods------------------------|*|*|*|*|*|
/* 获取对象的所有属性名数组 */
- (NSArray *)getAllPropertiesNameArr:(__unsafe_unretained Class)className {
    u_int count;
    objc_property_t *properties  = class_copyPropertyList(className, &count);
    NSMutableArray *propertiesArray = [NSMutableArray arrayWithCapacity:count];
    for (int i = 0; i < count ; i++) {
        const char *propertyName = property_getName(properties[i]);
        [propertiesArray addObject:[NSString stringWithUTF8String:propertyName]];
    }
    free(properties);
    return propertiesArray;
}
/**
 根据字典生成插入sql
 
 @param tableName 表名
 @param dataDic 参数字典
 @return 返回生成的sql
 */
- (NSString *)insertSQL:(NSString *)tableName
                dataDic:(NSDictionary *)dataDic {
    NSArray *keyArr = [dataDic allKeys];
    __block NSString *keyString = @"";
    __block NSString *valueString = @"";
    if (keyArr.count == 1) {
        keyString = [NSString stringWithFormat:@"(%@)", keyArr[0]];
        valueString = [NSString stringWithFormat:@"('%@')", [dataDic[keyArr[0]] objConvertToStr]];
    }else {
        [keyArr enumerateObjectsUsingBlock:^(NSString *obj, NSUInteger idx, BOOL * _Nonnull stop) {
            if (idx == keyArr.count - 1) {
                keyString = [NSString stringWithFormat:@"%@ %@)",keyString,obj];
                valueString = [NSString stringWithFormat:@"%@'%@')",valueString,[dataDic[obj] objConvertToStr]];
            }else {
                if ([keyString isEqualToString:@""]) {
                    keyString = [NSString stringWithFormat:@"(%@,",obj];
                    valueString = [NSString stringWithFormat:@"('%@',",[dataDic[obj] objConvertToStr]];
                }else {
                    keyString = [NSString stringWithFormat:@"%@ %@,",keyString,obj];
                    valueString = [NSString stringWithFormat:@"%@'%@',",valueString,[dataDic[obj] objConvertToStr]];
                }
            }
        }];
    }
    NSString *insertsql = [NSString stringWithFormat:@"INSERT INTO %@ %@ VALUES %@",tableName,keyString,valueString];
    return insertsql;
}
/**
 根据模型生成插入sql
 
 @param tableName 表名
 @param dataModel 参数模型
 @return 返回生成的sql
 */
- (NSString *)insertSQL:(NSString *)tableName
              dataModel:(Class)dataModel {
    NSDictionary *dataDic = dataModel.mj_keyValues;
    return [self insertSQL:tableName
                   dataDic:dataDic];
}

- (NSString *)searchSQL:(NSString *)tName
              searchDic:(NSDictionary *)searchDic {
    __block NSString *tempString = @"";
    [searchDic enumerateKeysAndObjectsUsingBlock:^(NSString *key,id value, BOOL * _Nonnull stop) {
        if ([tempString isEqualToString:@""]) {
            tempString = [NSString stringWithFormat:@"%@ = '%@'",key,[value objConvertToStr]];
        }else {
            tempString = [NSString stringWithFormat:@"%@ AND %@ = '%@'",tempString,key,[value objConvertToStr]];
        }
    }];
    NSString *searchSQL;
    if ([tempString isEqualToString:@""]) {
        searchSQL = [NSString stringWithFormat:@"SELECT * FROM %@",tName];
    }else {
        searchSQL = [NSString stringWithFormat:@"SELECT * FROM %@ WHERE %@",tName,tempString];
    }
    return searchSQL;
}

/**
 根据字典生成更新sql

 @param tName 表名
 @param searchDic 更新位置查询参数字典
 @param dataDic 更新参数字典
 @return 返回生成的更新sql
 */
- (NSString *)updateSQL:(NSString *)tName
              searchDic:(NSDictionary *)searchDic
                dataDic:(NSDictionary *)dataDic {
    __block NSString *tempDataStr = @"";
    __block NSString *tempSearchStr = @"";
    [dataDic enumerateKeysAndObjectsUsingBlock:^(NSString *key,id value, BOOL * _Nonnull stop) {
        if ([tempDataStr isEqualToString:@""]) {
            tempDataStr = [NSString stringWithFormat:@"%@ = '%@'",key,[value objConvertToStr]];
        }else {
            tempDataStr = [NSString stringWithFormat:@"%@,%@ = '%@'",tempDataStr,key,[value objConvertToStr]];
        }
    }];
    [searchDic enumerateKeysAndObjectsUsingBlock:^(NSString *key,id value, BOOL * _Nonnull stop) {
        if ([tempSearchStr isEqualToString:@""]) {
            tempSearchStr = [NSString stringWithFormat:@"%@ = '%@'",key,[value objConvertToStr]];
        }else {
            tempSearchStr = [NSString stringWithFormat:@"%@ AND %@ = '%@'",tempSearchStr,key,[value objConvertToStr]];
        }
    }];
    NSString *updatesql;
    if ([tempSearchStr isEqualToString:@""]) {
        updatesql = [NSString stringWithFormat:@"UPDATE %@ set %@",tName,tempDataStr];
    }else {
        updatesql = [NSString stringWithFormat:@"UPDATE %@ set %@ WHERE %@",tName,tempDataStr,tempSearchStr];
    }
    return updatesql;
}

- (NSString *)deleteSQL:(NSString *)tName
              deleteDic:(NSDictionary *)deleteDic {
    __block NSString *tempDeleteStr = @"";
    [deleteDic enumerateKeysAndObjectsUsingBlock:^(NSString *key,id value, BOOL * _Nonnull stop) {
        if ([tempDeleteStr isEqualToString:@""]) {
            tempDeleteStr = [NSString stringWithFormat:@"%@ = '%@'",key,[value objConvertToStr]];
        }else {
            tempDeleteStr = [NSString stringWithFormat:@"%@ AND %@ = '%@'",tempDeleteStr,key,[value objConvertToStr]];
        }
    }];
    NSString *deleteSQL;
    if ([tempDeleteStr isEqualToString:@""]) {
        deleteSQL = [NSString stringWithFormat:@"DELETE FROM %@",tName];
    }else {
        deleteSQL = [NSString stringWithFormat:@"DELETE FROM %@ WHERE %@",tName,tempDeleteStr];
    }
    return deleteSQL;
}

@end