swift支持多线程操作数据库类库-CoreDataManager

类库方法

• executeFetchRequest(request:)

同步获取数据

    var request: NSFetchRequest = NSFetchRequest(entityName: "MonkeyEntity")var myMonkeys:NSArray? = CoreDataManager.shared.executeFetchRequest(request)

异步获取数据

• executeFetchRequest(request:, completionHandler:)

Fetches with a completionHandler that returns an array with results asynchronously.

    var myMonkeys:NSArray?var request: NSFetchRequest = NSFetchRequest(entityName: "MonkeyEntity")CoreDataManager.shared.executeFetchRequest(request) { results inmyMonkeys = results!}

• save()

Saves the context, it doesn't matters the thread.

    CoreDataManager.shared.save()

• deleteEntity(object:)

Deletes the NSManagedObject sent

    CoreDataManager.shared.deleteEntity(item as MonkeyEntity)

源码地址:https://github.com/mdelamata/CoreDataManager-Swift

CoreDataManagaer-swift代码

 import Foundationimport CoreDataclass CoreDataManager: NSObject {let storeName="dev-db.sqlite"
let dataModelName="Model"var _managedObjectContext:NSManagedObjectContext?=nil
var _managedObjectModel:NSManagedObjectModel?=nil
var _persistentStoreCoordinator:NSPersistentStoreCoordinator?=nilclass var shared:CoreDataManager{get{struct Static{static var instance:CoreDataManager?=nilstatic var token:dispatch_once_t = 0}dispatch_once(&Static.token){Static.instance=CoreDataManager()}return Static.instance!}
}var managedObjectContext:NSManagedObjectContext{if NSThread.isMainThread(){if !(_managedObjectContext != nil){let coordinator = self.persistentStoreCoordinatorif coordinator != NSNull() {_managedObjectContext=NSManagedObjectContext(concurrencyType: NSManagedObjectContextConcurrencyType.MainQueueConcurrencyType)_managedObjectContext!.persistentStoreCoordinator=coordinator}return _managedObjectContext!}}else{var threadContext:NSManagedObjectContext?=NSThread.currentThread().threadDictionary["NSManagedObjectContext"] as? NSManagedObjectContext;if threadContext==nil{threadContext = NSManagedObjectContext(concurrencyType: .PrivateQueueConcurrencyType)threadContext!.parentContext = _managedObjectContextthreadContext!.name=NSThread.currentThread().descriptionNSThread.currentThread().threadDictionary["NSManagedObjectContext"] = threadContextNSNotificationCenter.defaultCenter().addObserver(self, selector: "contextWillSave", name: NSManagedObjectContextWillSaveNotification, object: threadContext)}else{print("using old context")}return threadContext!;}return _managedObjectContext!
}// Returns the managed object model for the application.
// If the model doesn't already exist, it is created from the application's model.
var managedObjectModel:NSManagedObjectModel{if !(_managedObjectModel != nil){let modelURL=NSBundle.mainBundle().URLForResource(dataModelName, withExtension: "momd")_managedObjectModel=NSManagedObjectModel(contentsOfURL: modelURL!)}return _managedObjectModel!
}var persistentStoreCoordinator:NSPersistentStoreCoordinator{if !(_persistentStoreCoordinator != nil){let storeURL=self.applicationDocumentsDirectory.URLByAppendingPathComponent(storeName)//var error:NSError?=nil_persistentStoreCoordinator=NSPersistentStoreCoordinator(managedObjectModel: self.managedObjectModel)do {try _persistentStoreCoordinator!.addPersistentStoreWithType(NSSQLiteStoreType, configuration: nil, URL: storeURL, options: self.databaseOptions())} catch _ as NSError {//error = error1abort()}}return _persistentStoreCoordinator!;
}// #pragma mark - fetchesfunc executeFetchRequest(request:NSFetchRequest)->Array<AnyObject>?{var results:Array<AnyObject>?self.managedObjectContext.performBlockAndWait{var fetchError:NSError?do {results=try self.managedObjectContext.executeFetchRequest(request)} catch let error as NSError {fetchError = errorresults = nil} catch {fatalError()};if let error=fetchError{print("Warning!! \(error.description)")}}return results;
}func executeFetchRequest(request:NSFetchRequest,completionHandler:(results:Array<AnyObject>?) -> Void){self.managedObjectContext.performBlock(){var fetchError:NSError?var results:Array<AnyObject>?do {results=try self.managedObjectContext.executeFetchRequest(request)} catch let error as NSError {fetchError = errorresults = nil} catch {fatalError()}if let error=fetchError {print("Warning!! \(error.description)")}completionHandler(results: results)}
}func save(){let context:NSManagedObjectContext = self.managedObjectContextif context.hasChanges {context.performBlock{var saveError:NSError?let saved: Booldo {try context.save()saved = true} catch let error as NSError {saveError = errorsaved = false} catch {fatalError()};if !saved {if let error = saveError{print("Warning!! Saving error \(error.description)")}}if (context.parentContext != nil) {context.parentContext!.performBlockAndWait{var saveError:NSError?let saved: Booldo {try context.parentContext!.save()saved = true} catch let error as NSError {saveError = errorsaved = false} catch {fatalError()}if !saved{if let error = saveError{print("Warning!! Saving parent error \(error.description)")}}}}}}}func contextWillSave(notification:NSNotification){let context : NSManagedObjectContext! = notification.object as! NSManagedObjectContextlet insertedObjects:NSSet = context.insertedObjects;if insertedObjects.count != 0 {var obtainError:NSError?do {try context.obtainPermanentIDsForObjects(insertedObjects.allObjects as! [NSManagedObject])} catch let error as NSError {obtainError = error}if let error = obtainError {print("Warning!! obtaining ids error \(error.description)")}}
}func deleteEntity(object:NSManagedObject){object.managedObjectContext?.deleteObject(object)
}func deleteTable(tableName:String){let managedObjectContext=self.managedObjectContext;let entity=NSEntityDescription.entityForName(tableName, inManagedObjectContext: managedObjectContext)let request=NSFetchRequest()request.includesPropertyValues=false;request.entity=entity;let items=self.executeFetchRequest(request);if (items != nil&&items!.count>0) {for obj in items! {let item = obj as! NSManagedObject;self.deleteEntity(item)}self.save()}
}// #pragma mark - Application's Documents directory// Returns the URL to the application's Documents directory.
var applicationDocumentsDirectory: NSURL {
let urls = NSFileManager.defaultManager().URLsForDirectory(.DocumentDirectory, inDomains: .UserDomainMask)//  println(urls[urls.endIndex-1] as NSURL)return urls[urls.endIndex-1] 
}func databaseOptions() -> Dictionary <String,Bool> {var options =  Dictionary<String,Bool>()options[NSMigratePersistentStoresAutomaticallyOption] = trueoptions[NSInferMappingModelAutomaticallyOption] = truereturn options
}}