NetNewsWire/Frameworks/RSDatabase/DatabaseTable.swift

116 lines
2.8 KiB
Swift
Raw Normal View History

//
// DatabaseTable.swift
// RSDatabase
//
// Created by Brent Simmons on 7/16/17.
// Copyright © 2017 Ranchero Software, LLC. All rights reserved.
//
import Foundation
2017-08-21 00:56:58 +02:00
public protocol DatabaseTable {
2017-08-21 00:56:58 +02:00
var name: String { get }
2017-07-17 05:51:08 +02:00
}
public extension DatabaseTable {
// MARK: Fetching
public func selectRowsWhere(key: String, equals value: Any, in database: FMDatabase) -> FMResultSet? {
2017-07-17 05:51:08 +02:00
return database.rs_selectRowsWhereKey(key, equalsValue: value, tableName: name)
2017-07-17 05:51:08 +02:00
}
public func selectRowsWhere(key: String, inValues values: [Any], in database: FMDatabase) -> FMResultSet? {
2017-08-06 21:37:47 +02:00
if values.isEmpty {
return nil
}
return database.rs_selectRowsWhereKey(key, inValues: values, tableName: name)
}
// MARK: Deleting
2017-07-17 05:51:08 +02:00
public func deleteRowsWhere(key: String, equalsAnyValue values: [Any], in database: FMDatabase) {
if values.isEmpty {
return
}
database.rs_deleteRowsWhereKey(key, inValues: values, tableName: name)
}
// MARK: Updating
public func updateRowsWithValue(_ value: Any, valueKey: String, whereKey: String, matches: [Any], database: FMDatabase) {
let _ = database.rs_updateRows(withValue: value, valueKey: valueKey, whereKey: whereKey, inValues: matches, tableName: self.name)
}
public func updateRowsWithDictionary(_ dictionary: NSDictionary, whereKey: String, matches: Any, database: FMDatabase) {
let _ = database.rs_updateRows(with: dictionary as! [AnyHashable : Any], whereKey: whereKey, equalsValue: matches, tableName: self.name)
}
// MARK: Saving
2017-08-05 20:12:45 +02:00
public func insertRows(_ dictionaries: [NSDictionary], insertType: RSDatabaseInsertType, in database: FMDatabase) {
2017-08-05 20:12:45 +02:00
dictionaries.forEach { (oneDictionary) in
let _ = database.rs_insertRow(with: oneDictionary as [NSObject: AnyObject], insertType: insertType, tableName: self.name)
}
}
// MARK: Counting
2017-08-31 22:35:48 +02:00
func numberWithCountResultSet(_ resultSet: FMResultSet) -> Int {
2017-08-31 22:35:48 +02:00
guard resultSet.next() else {
return 0
}
2017-08-31 22:35:48 +02:00
return Int(resultSet.int(forColumnIndex: 0))
}
func numberWithSQLAndParameters(_ sql: String, _ parameters: [Any], in database: FMDatabase) -> Int {
2017-08-31 22:35:48 +02:00
if let resultSet = database.executeQuery(sql, withArgumentsIn: parameters) {
return numberWithCountResultSet(resultSet)
}
return 0
}
2017-08-06 21:37:47 +02:00
// MARK: Mapping
func mapResultSet<T>(_ resultSet: FMResultSet, _ callback: (_ resultSet: FMResultSet) -> T?) -> [T] {
var objects = [T]()
while resultSet.next() {
if let obj = callback(resultSet) {
objects += [obj]
}
}
return objects
}
}
public extension FMResultSet {
public func flatMap<T>(_ callback: (_ row: FMResultSet) -> T?) -> [T] {
var objects = [T]()
while next() {
if let obj = callback(self) {
objects += [obj]
}
}
close()
return objects
}
public func mapToSet<T>(_ callback: (_ row: FMResultSet) -> T?) -> Set<T> {
return Set(flatMap(callback))
}
}