dkm

Ripped a part utility folder and shoved it into a lib. Changed a lot of Utility prefixes to the modules name. This contains breaking changes. Scripts that use 0.2.0 will need to update to match the new format

lib/server/sqlHandler.lua

@@ -0,0 +1,66 @@
+SQL = {}
+
+Require("lib/MySQL.lua", "oxmysql")
+
+function SQL.Create(tableName, columns)
+    assert(MySQL, "Tried using module SQL without MySQL being loaded")
+    local columnsList = {}
+    for i, column in pairs(columns) do
+        table.insert(columnsList, string.format("%s %s", column.name, column.type))
+    end
+    
+    local query = string.format("CREATE TABLE IF NOT EXISTS %s (%s);",
+        tableName,
+        table.concat(columnsList, ", ")
+    )
+    
+    MySQL.query.await(query)
+end
+
+--  insert if not exist otherwise update
+function SQL.InsertOrUpdate(tableName, data)
+    assert(MySQL, "Tried using module SQL without MySQL being loaded")
+    local columns = {}
+    local values = {}
+    local updates = {}
+
+    for column, value in pairs(data) do
+        table.insert(columns, column)
+        table.insert(values, "'" .. value .. "'") -- Ensure values are properly quoted
+        table.insert(updates, column .. " = VALUES(" .. column .. ")") -- Use VALUES() for update
+    end
+
+    local query = string.format(
+        "INSERT INTO %s (%s) VALUES (%s) ON DUPLICATE KEY UPDATE %s;",
+        tableName,
+        table.concat(columns, ", "),
+        table.concat(values, ", "),
+        table.concat(updates, ", ")
+    )
+
+    MySQL.query.await(query)
+end
+
+function SQL.Get(tableName, where)
+    assert(MySQL, "Tried using module SQL without MySQL being loaded")
+    local query = string.format("SELECT * FROM %s WHERE %s;", tableName, where)
+    local result = MySQL.query.await(query)
+    return result
+end
+
+function SQL.GetAll(tableName)
+    assert(MySQL, "Tried using module SQL without MySQL being loaded")
+    local query = string.format("SELECT * FROM %s;", tableName)
+    local result = MySQL.query.await(query)
+    return result
+end
+
+function SQL.Delete(tableName, where)
+    assert(MySQL, "Tried using module SQL without MySQL being loaded")
+    local query = string.format("DELETE FROM %s WHERE %s;", tableName, where)
+    MySQL.query.await(query)
+end
+
+exports('SQL', SQL)
+
+return SQL