欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

iOS FMDB 在swift4.0中使用

程序员文章站 2022-05-31 17:38:27
...

1.封装的一个不用写sqlite语句的数据库类,使用的是swift4.0,运用了runtime机制获取属性名,和属性值,通过模型直接调用方法就可以进行数据库操作,先看看效果图
iOS FMDB 在swift4.0中使用
2.先对封装的类进行简单的介绍
iOS FMDB 在swift4.0中使用

2-1. 对QYPSQLiteManager内代码

import Foundation
import FMDB
class QYPSQLiteManager{
    static let shared = QYPSQLiteManager()
    var db = FMDatabase()
    var queue = FMDatabaseQueue()
    init() {
        let dbName = "status.db"
        var path = NSSearchPathForDirectoriesInDomains(.documentDirectory, .userDomainMask, true)[0]
        path = (path as NSString).appendingPathComponent(dbName)
        print("数据库的路径 " + path)
        // 1 .使用FMDatabaseQueue
        queue = FMDatabaseQueue(path: path)
    }
}

2-2. QYPObject+Extension

import Foundation
extension NSObject{
    /// 创建数据表
    func createTable(arr:[String]) {
        var sql = "create table if not exists \(self.classForCoder) (id integer primary key autoincrement"
        for str in arr {
            sql += ",\(str) text"
        }
        sql += ");"
        // 2. 执行 SQL - FMDB 的内部队列,串行队列,同步执行
        // 可以保证同一时间,只有一个任务操作数据库,从而保证数据库的读写安全!
        QYPSQLiteManager.shared.queue.inDatabase { (db) in
            // 只有在创表的时候,使用执行多条语句,可以一次创建多个数据表
            // 在执行增删改的时候,一定不要使用 statements 方法,否则有可能会被注入!
            if db.executeStatements(sql) == true {
                print("创表成功")
            } else {
                print("创表失败")
            }
        }
    }
    /// 查询数据表是否存在
    func tableViewIsExists() -> Bool{
        let isTableOkSql = "select count(*) as 'count' from sqlite_master where type ='table' and name = '\(self.classForCoder)';"
        var tempCount:Int64 = 0
        // 判断表是否已经存在
        QYPSQLiteManager.shared.queue.inDatabase { (db) in
            guard let rs = db.executeQuery(isTableOkSql, withArgumentsIn: []) else {
                return
            }
            while rs.next() {
                tempCount = Int64(rs.int(forColumn: "count"))
            }
        }
        if tempCount == 0{
            return false
        }
        return true

    }

}

2-3 *这里是我们需要使用的接口QYPDBApi类

import Foundation
extension NSObject {
    /// 插入数据
    func insertData(){
        var insertSql = "insert into \(self.classForCoder)"
        let arr = self.propertyList()
        var key = " ("
        var values = " values("
        for str in arr {
            key += "\(str),"
            values += "?,"
        }
        key.remove(at:key.index(before: key.endIndex))
        values.remove(at:values.index(before: values.endIndex))
        insertSql += key + ")" + values + ");"
        let valuesArr = self.getValueOfProperty()
        QYPSQLiteManager.shared.queue.inTransaction { (db, rollback) in
            // 执行 SQL
            if db.executeUpdate(insertSql, withArgumentsIn: valuesArr) == false {
                // 回滚
                rollback.pointee = true
                print("插入数据失败")
            }else{
                print("插入数据成功")
            }
        }
    }
    /// 删除数据
    ///
    /// - Parameter deletStr: "name = 'jacob'"
    func delete(deletStr:String){
        let deleteSql = "delete from \(self.classForCoder) where \(deletStr);"
        print(deleteSql)
        QYPSQLiteManager.shared.queue.inDatabase { (db) in
            if db.executeUpdate(deleteSql, withArgumentsIn: []) == true {
                print("\(self.classForCoder)表删除了\(db.changes)条记录")

            }else {
                print("\(self.classForCoder)表数据操作失败")
            }
        }
    }
    /// 跟新语句全部模型里面的数据全部跟新
    func updateData(whereStr:String){
        /// 定义的属性
        var updateSql = "UPDATE \(self.classForCoder) SET"
        /// 获取到的模型的属性名
        let columnArr = self.propertyList()
        /// 获取到的模型的属性值
        let valueArr = self.getValueOfProperty()
        for i in 0..<columnArr.count {
            updateSql += " \(columnArr[i]) = '\(valueArr[i])',"
        }
        updateSql.remove(at:updateSql.index(before: updateSql.endIndex))
        updateSql += " WHERE \(whereStr);"
        print(updateSql)
        QYPSQLiteManager.shared.queue.inDatabase { (db) in
            if db.executeUpdate(updateSql, withArgumentsIn: []) == true {
                print("\(self.classForCoder)改变了\(db.changes)条记录")
            }else {
                print("\(self.classForCoder)表数据操作失败")
            }
        }
    }
    /// 表中数据全部查出默认按升序排列
    // FIXME:先放在这里,还未处理的是 ORDER BY id DESC 别的东西,现在只做到了id的降序排列
    func selectData(whereStr:String,ORDER_BY:String = "id ASC") -> [[String:AnyObject]]{
        var selectSql = "SELECT id,"
        let columnArr = self.propertyList()
        for str in columnArr {
            selectSql += " \(str),"
        }
        selectSql.remove(at:selectSql.index(before: selectSql.endIndex))

        selectSql += " FROM \(self.classForCoder) WHERE \(whereStr) ORDER BY \(ORDER_BY);"
        print(selectSql)
        var result = [[String: AnyObject]]()
        QYPSQLiteManager.shared.queue.inDatabase { (db) in
            guard let rs = db.executeQuery(selectSql, withArgumentsIn: []) else {
                return
            }
            while rs.next() {
                // FIXME:这里还想到好的办法将其以模型数组的形式return
                // 这里先以字典数组的形式返回回去吧!
                //                let myClass = self.classForCoder
                // 列数
                var dic = [String:AnyObject]()
                let colCount = rs.columnCount
                for col in 0..<colCount {
                    guard let name = rs.columnName(for: col),
                        let value = rs.object(forColumnIndex: col) else {
                            continue
                    }
                    // 在这里通过运行时给类添加属性,并且设置属性值
                    dic[name] = value as AnyObject
                }
                result.append(dic)
            }
        }
        return result
    }
}

2-4…这里是runtime获取属性值,和属性名

import Foundation
extension NSObject{
    /// 通过字典设置属性值
    ///
    /// - Parameter dic: [属性名:属性值]
    /// - Returns: 是否设置成功
    func setValueOfProperty(dic:[String:String])->Bool{
        let allPropertys = self.propertyList()
        for key in allPropertys {
            self.setValue(dic[key], forKey: key)
        }
        return true
    }
    /// 获取属性值
    ///
    /// - Returns: 返回获取到的属性值数组
    func getValueOfProperty()->[String]{
        let allPropertys = self.propertyList()
        var values = [String]()
        for key in allPropertys {
            let val = self.value(forKey: key) as? String ?? ""
            values.append(val)
        }
        return values
    }
    ///[使用运行时]获取当前类所有的属性数组
    func propertyList() -> [String] {
        var count :UInt32 = 0
        //获取‘类’的属性列表
        guard let list = class_copyPropertyList(self.classForCoder, &count) else{
            return []
        }
        var arr = [String]()
        for i in 0..<Int(count) {
            //根据下标 获取属性
            let a = list[i]
            //获取属性的名称
            let cName = property_getName(a)
            let n = String(utf8String:cName)
            arr.append(n ?? "")
        }
        // 在这个方法里面创建数据表.
        if tableViewIsExists() == false{
            createTable(arr: arr)
        }

        return arr
    }
}

4.*同时项目运用了MVVM的使用,基本上和实际项目模式一直,可以值得借鉴

iOS FMDB 在swift4.0中使用

5.介绍结束.完整的代码已经提交github地址
https://github.com/13670242169/QYPSQLFMDBManager.git
要是可以帮到大伙,求点赞,要是哪里写的不足,求指教

相关标签: sqlite