//
//  NSObject+LHModelExecute.m
//  LHDBDemo
//
//  Created by 3wchina01 on 16/2/15.
//  Copyright © 2016年 李浩. All rights reserved.
//

#import "NSObject+LHDB.h"
#import "LHPredicate.h"
#import <objc/runtime.h>
#import "LHDBPath.h"
#import "LHSqlite.h"
#import "NSObject+LHModel.h"
#import "LHModelStateMent.h"


#define run_in_queue(...) dispatch_async([self executeQueue], ^{\
__VA_ARGS__; \
})

#define DatabasePath [[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) firstObject]stringByAppendingPathComponent:@"filedata.sqlite"]

static NSString* const DatabaseFilePath = @"DatabaseFilePath";
static NSString* const DataBaseExecute = @"DataBaseExecute";
static NSString* const DataBaseQueue = @"DataBaseQueue";

static LHSqlite* sqlite;

@implementation NSObject (LHDB)

- (dispatch_queue_t)executeQueue
{
    static dispatch_queue_t executeQueue;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        executeQueue = dispatch_queue_create("com.sancai.lhdb", DISPATCH_QUEUE_SERIAL);
    });
    return executeQueue;
}

+ (dispatch_queue_t)executeQueue
{
    return [[self new] executeQueue];
}

- (NSString*)dbPath
{
    if ([LHDBPath instanceManagerWith:nil].dbPath.length == 0) {
        return DatabasePath;
    }else
        return [LHDBPath instanceManagerWith:nil].dbPath;
}

+ (NSString*)dbPath
{
    if ([LHDBPath instanceManagerWith:nil].dbPath.length == 0) {
        return DatabasePath;
    }else
        return [LHDBPath instanceManagerWith:nil].dbPath;
}

- (void)setFilePath:(NSString *)filePath
{
    objc_setAssociatedObject(self, &DatabaseFilePath, filePath, OBJC_ASSOCIATION_RETAIN_NONATOMIC);
}

- (NSString*)filePath
{
    return objc_getAssociatedObject(self, &DatabaseFilePath);
}

+ (void)createTable
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:createTableString(self) object:nil executeType:LHSqliteTypeWrite success:nil fail:nil];
}

+ (void)addColum:(NSString*)name
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:addColum(self, name) object:nil executeType:LHSqliteTypeWrite success:nil fail:nil];
}

- (void)save
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:insertString(self) object:self executeType:LHSqliteTypeWrite success:nil fail:nil];
}

+ (void)saveWithDic:(NSDictionary*)dic
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:insertStringWithDic(self, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:nil];
}

- (void)saveWithIfError:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:insertString(self) object:self executeType:LHSqliteTypeWrite success:nil fail:error];
}

+ (void)saveWithDic:(NSDictionary*)dic error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:insertStringWithDic(self, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:error];
}

- (void)updateWithPredicate:(LHPredicate*)predicate
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:updateString(self, predicate) object:self executeType:LHSqliteTypeWrite success:nil fail:nil];
}

+ (void)updateWithDic:(NSDictionary*)dic predicate:(LHPredicate*)predicate
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:updateStringWithDic(self, predicate, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:nil];
}

- (void)updateWithPredicate:(LHPredicate*)predicate error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:updateString(self, predicate) object:self executeType:LHSqliteTypeWrite success:nil fail:error];
}

+ (void)updateWithDic:(NSDictionary*)dic predicate:(LHPredicate*)predicate error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:updateStringWithDic(self, predicate, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:error];
}

+ (void)deleteWithPredicate:(LHPredicate*)predicate
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:deleteString(self, predicate) object:nil executeType:LHSqliteTypeWrite success:nil fail:nil];
}

+ (void)deleteWithPredicate:(LHPredicate*)predicate error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    [sqlite executeSQLWithSqlstring:deleteString(self, predicate) object:nil executeType:LHSqliteTypeWrite success:nil fail:error];
}

+ (NSArray*)selectWithPredicate:(LHPredicate*)predicate
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    __block NSMutableArray* array = [NSMutableArray array];
    [sqlite executeSQLWithSqlstring:selectString(self, predicate) object:nil executeType:LHSqliteTypeRead success:^(NSArray *result) {
        for (NSDictionary* dic in result) {
            [array addObject:[self lh_ModelWithDictionary:dic]];
        }
    } fail:nil];
    return array;
}

+ (NSArray*)selectWithPredicate:(LHPredicate*)predicate error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    __block NSMutableArray* array = [NSMutableArray array];
    [sqlite executeSQLWithSqlstring:selectString(self, predicate) object:nil executeType:LHSqliteTypeRead success:^(NSArray *result) {
        for (NSDictionary* dic in result) {
            [array addObject:[self lh_ModelWithDictionary:dic]];
        }
    } fail:error];
    return array;
}

+ (void)inQueueCreateTable
{
    run_in_queue([self createTable]);
}

+ (void)inQueueAddColum:(NSString*)name
{
    run_in_queue([self addColum:name]);
}

- (void)inQueueSave
{
    run_in_queue([self save]);
}

+ (void)inQueueSaveWithDic:(NSDictionary*)dic
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    run_in_queue([sqlite executeSQLWithSqlstring:insertStringWithDic(self, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:nil]);
}

- (void)inQueueSaveWithIfError:(executeError)fail
{
    run_in_queue([self saveWithIfError:fail]);
}

+ (void)inQueueSaveWithDic:(NSDictionary*)dic error:(executeError)fail
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    run_in_queue([sqlite executeSQLWithSqlstring:insertStringWithDic(self, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:fail]);
}

- (void)inQueueUpdateWithPredicate:(LHPredicate*)predicate
{
    run_in_queue([self updateWithPredicate:predicate]);
}

+ (void)inQueueUpdateWithDic:(NSDictionary*)dic predicate:(LHPredicate*)predicate
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    run_in_queue([sqlite executeSQLWithSqlstring:updateStringWithDic(self, predicate, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:nil]);
}

- (void)inQueueUpdateWithPredicate:(LHPredicate*)predicate error:(executeError)fail
{
    run_in_queue([self updateWithPredicate:predicate error:fail]);
}

+ (void)inQueueUpdateWithDic:(NSDictionary*)dic predicate:(LHPredicate *)predicate error:(executeError)error
{
    LHSqlite* sqlite = [LHSqlite shareInstance];
    sqlite.sqlPath = [self dbPath];
    run_in_queue([sqlite executeSQLWithSqlstring:updateStringWithDic(self, predicate, dic) object:dic executeType:LHSqliteTypeWrite success:nil fail:error]);
}

+ (void)inQueueDeleteWithPredicate:(LHPredicate*)predicate
{
    run_in_queue([self deleteWithPredicate:predicate]);
}

+ (void)inQueueDeleteWithPredicate:(LHPredicate*)predicate error:(executeError)fail
{
    run_in_queue([self deleteWithPredicate:predicate error:fail]);
}

+ (void)inQueueSelectWithPredicate:(LHPredicate*)predicate result:(void(^)(NSArray* resultArray))result
{
    run_in_queue(result([self selectWithPredicate:predicate]));
}

+ (void)inQueueSelectWithPredicate:(LHPredicate*)predicate result:(void(^)(NSArray* resultArray))result error:(executeError)fail
{
    
    run_in_queue(result([self selectWithPredicate:predicate error:fail]));
}

@end