Proyectos de Subversion Iphone Microlearning - Inconcert

//
//  TopicDao.swift
//  twogetskills
//
//  Created by Efrain Yanez Recanatini on 2/21/22.
//

import SwiftUI
import SQLite3

class TopicDao {
    private var database = Environment(\.database).wrappedValue
    private let SQLITE_TRANSIENT = unsafeBitCast(-1, to: sqlite3_destructor_type.self)

    func selectByUuid(uuid: String)-> TopicModel {
        let db = database.open()
        var model = TopicModel()
        
        var query = "SELECT "
        query = query + Constants.TABLE_TOPIC_FIELD_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_COMPANY_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_NAME + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_DESCRIPTION + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_IMAGE + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_POSITION + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_ADDED_ON + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_UPDATED_ON
        query = query + " FROM " + Constants.TABLE_TOPIC
        query = query + " WHERE " + Constants.TABLE_TOPIC_FIELD_UUID + " = '\(uuid)'  LIMIT 1;"
 
        var statement : OpaquePointer? = nil
        
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
            if (sqlite3_step(statement) == SQLITE_ROW) {
                model.uuid = String(describing: String(cString: sqlite3_column_text(statement, 0)))
                model.companyUuid = String(describing: String(cString: sqlite3_column_text(statement, 1)))
                model.name = String(describing: String(cString: sqlite3_column_text(statement, 2)))
                model.description = String(describing: String(cString: sqlite3_column_text(statement, 3)))
                model.image = String(describing: String(cString: sqlite3_column_text(statement, 4)))
                model.position = Int(sqlite3_column_int(statement, 5))
                model.addedOn = String(describing: String(cString: sqlite3_column_text(statement, 6)))
                model.updatedOn = String(describing: String(cString: sqlite3_column_text(statement, 7)))
                //print("\nSuccessfully get record")
                
            }
        } else {
           
        }
        sqlite3_finalize(statement)
        return model
    }


    func selectAllBycompanyUuid(companyUuid: String)-> [TopicModel] {
        let db = database.open()
        var records = [TopicModel]()
        
        var query = "SELECT "
        query = query + Constants.TABLE_TOPIC_FIELD_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_COMPANY_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_NAME + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_DESCRIPTION + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_IMAGE + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_POSITION + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_ADDED_ON + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_UPDATED_ON
        query = query + " FROM " + Constants.TABLE_TOPIC
        query = query + " WHERE " + Constants.TABLE_TOPIC_FIELD_COMPANY_UUID + " = '\(companyUuid)' "
        query = query + " ORDER BY  " + Constants.TABLE_TOPIC_FIELD_NAME + " ;"
        
        var statement : OpaquePointer? = nil
        
        
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
            while (sqlite3_step(statement) == SQLITE_ROW) {
                
                var  model = TopicModel()
                model.uuid = String(describing: String(cString: sqlite3_column_text(statement, 0)))
                model.companyUuid = String(describing: String(cString: sqlite3_column_text(statement, 1)))
                model.name = String(describing: String(cString: sqlite3_column_text(statement, 2)))
                model.description = String(describing: String(cString: sqlite3_column_text(statement, 3)))
                model.image = String(describing: String(cString: sqlite3_column_text(statement, 4)))
                model.position = Int(sqlite3_column_int(statement, 5))
                model.addedOn = String(describing: String(cString: sqlite3_column_text(statement, 6)))
                model.updatedOn = String(describing: String(cString: sqlite3_column_text(statement, 7)))
                
                records.append(model)
                
            }
        } else {
           
        }
        sqlite3_finalize(statement)
        return records
    }

    func selectAll()-> [TopicModel] {
        let db = database.open()
        var records = [TopicModel]()
        var query = "SELECT "
        query = query + Constants.TABLE_TOPIC_FIELD_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_COMPANY_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_NAME + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_DESCRIPTION + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_IMAGE + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_POSITION + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_ADDED_ON + " , "
        query = query + Constants.TABLE_TOPIC_FIELD_UPDATED_ON
        query = query + " FROM " + Constants.TABLE_TOPIC
        query = query + " ORDER BY  " + Constants.TABLE_TOPIC_FIELD_NAME + " ;"
        
        //print("query = \(query) ")
        var statement : OpaquePointer? = nil
        
        
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
            while (sqlite3_step(statement) == SQLITE_ROW) {
                
                var  model = TopicModel()
                model.uuid = String(describing: String(cString: sqlite3_column_text(statement, 0)))
                model.companyUuid = String(describing: String(cString: sqlite3_column_text(statement, 1)))
                model.name = String(describing: String(cString: sqlite3_column_text(statement, 2)))
                model.description = String(describing: String(cString: sqlite3_column_text(statement, 3)))
                model.image = String(describing: String(cString: sqlite3_column_text(statement, 4)))
                model.position = Int(sqlite3_column_int(statement, 5))
                model.addedOn = String(describing: String(cString: sqlite3_column_text(statement, 6)))
                model.updatedOn = String(describing: String(cString: sqlite3_column_text(statement, 7)))
    
                
                records.append(model)
                
            }
        } else {
           
        }
        sqlite3_finalize(statement)
        return records
    }
    
    func getCount() -> Int {
        let db = database.open()
        let query = "SELECT COUNT(*) AS total FROM " + Constants.TABLE_TOPIC;

        var statement : OpaquePointer? = nil
        var count = 0;
        
        
        if (sqlite3_prepare(db, query, -1, &statement, nil) == SQLITE_OK) {
            if(sqlite3_step(statement) == SQLITE_ROW){
                count = Int(sqlite3_column_int(statement, 0))
                //print("\(count)")
            }
        } else {
            count = -1
           
        }
        sqlite3_finalize(statement)
        return count
    }
    
    func insert(topic : TopicModel) {
        let db = database.open()
        var query = "INSERT INTO " + Constants.TABLE_TOPIC + " ( "
        query = query + Constants.TABLE_TOPIC_FIELD_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_COMPANY_UUID + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_NAME + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_DESCRIPTION + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_IMAGE + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_POSITION + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_ADDED_ON + ", "
        query = query + Constants.TABLE_TOPIC_FIELD_UPDATED_ON
        query = query + " ) VALUES (?, ?, ?, ?, ?, ?, ?, ?);"
        var statement : OpaquePointer?
        
           
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
                   
            sqlite3_bind_text(statement, 1, topic.uuid, -1, SQLITE_TRANSIENT)
            sqlite3_bind_text(statement, 2, topic.companyUuid, -1 , SQLITE_TRANSIENT)
            sqlite3_bind_text(statement, 3, topic.name , -1, SQLITE_TRANSIENT)
            sqlite3_bind_text(statement, 4, topic.description , -1, SQLITE_TRANSIENT)
            sqlite3_bind_text(statement, 5, topic.image , -1, SQLITE_TRANSIENT)
            sqlite3_bind_int(statement, 6, Int32(topic.position))
            sqlite3_bind_text(statement, 7, topic.addedOn , -1, SQLITE_TRANSIENT)
            sqlite3_bind_text(statement, 8, topic.updatedOn , -1, SQLITE_TRANSIENT)

           if (sqlite3_step(statement) != SQLITE_DONE) {
                print("No se pudo insertar un registro en la tabla: \(Constants.TABLE_TOPIC)")
               
            
           }
        } else {
            print("Fallo la preparación del insertar un registro en la tabla: \(Constants.TABLE_TOPIC)")
            
           
        }
       
        sqlite3_finalize(statement)
    }

    func update(topic: TopicModel) {
        let db = database.open()
        var query = "UPDATE " + Constants.TABLE_TOPIC
        query = query + " SET " + Constants.TABLE_TOPIC_FIELD_NAME + " = '\(topic.name)', "
        query = query + Constants.TABLE_TOPIC_FIELD_DESCRIPTION + " = '\(topic.description)', "
        query = query + Constants.TABLE_TOPIC_FIELD_IMAGE + " = '\(topic.image)', "
        query = query + Constants.TABLE_TOPIC_FIELD_POSITION + " = '\(topic.position)', "
        query = query + Constants.TABLE_TOPIC_FIELD_ADDED_ON + " = '\(topic.addedOn)', "
        query = query + Constants.TABLE_TOPIC_FIELD_UPDATED_ON + " = '\(topic.updatedOn)' "
        query = query + " WHERE " + Constants.TABLE_TOPIC_FIELD_UUID + " = '\(topic.uuid)';"
        var statement : OpaquePointer? = nil
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
            if (sqlite3_step(statement) != SQLITE_DONE) {
                print("No se pudo actualizar un registro en la tabla: \(Constants.TABLE_TOPIC) ")
               
            }
        } else {
            print("Fallo la preparación de la actualización de un registro en la tabla \(Constants.TABLE_TOPIC) ")
           
        }
        sqlite3_finalize(statement)
    }

    func remove(uuid: String) {
        let db = database.open()
        let query = "DELETE FROM " + Constants.TABLE_TOPIC
            + " WHERE " + Constants.TABLE_TOPIC_FIELD_UUID + " = '\(uuid)' ;"
        var statement : OpaquePointer? = nil
        if (sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK) {
            if (sqlite3_step(statement) != SQLITE_DONE) {
                print("No se pudo borrar el registro con el uuid: \(uuid) en la tabla: \(Constants.TABLE_TOPIC)")
               
            }
        } else {
            print("Fallo la preparación del borrado del registro con el uuid: \(uuid) en la tabla: \(Constants.TABLE_TOPIC)" )
           
        }
        sqlite3_finalize(statement)
    }

    func removeAll() {
        let db = database.open()
        let query = "DELETE FROM " + Constants.TABLE_TOPIC + ";"
        var statement : OpaquePointer? = nil
        if sqlite3_prepare_v2(db, query, -1, &statement, nil) == SQLITE_OK{
            if sqlite3_step(statement) != SQLITE_DONE {
                print("Fallo el borrado de todos los registros en la tabla: \(Constants.TABLE_TOPIC)")
               
            }
        } else {
            print("No se pudo preparar el borrado de todos los registros en la tabla: \(Constants.TABLE_TOPIC) ")
           
        }
        sqlite3_finalize(statement)
    }
    
}