diff --git a/imports/mysql/server.lua b/imports/mysql/server.lua
new file mode 100644
index 0000000..da15364
--- /dev/null
+++ b/imports/mysql/server.lua
@@ -0,0 +1,194 @@
+local MySQL = {}
+
+MySQL.ready = function(cb)
+	CreateThread(function()
+		repeat Wait(50) until GetResourceState('oxmysql') == 'started'
+		cb()
+	end)
+end
+
+local Store = setmetatable({currentId=0}, {
+	__call = function(self, query)
+		local id = self.currentId + 1
+		self.currentId = id
+		self[id] = query
+		return id
+	end
+})
+
+MySQL.store = function(query)
+	local type = type(query)
+	assert(type == 'string', ('MySQL.store requires a string (received %s)'):format(type))
+	return Store(query)
+end
+
+local function safeArgs(query, parameters, cb, transaction)
+	if type(query) == 'number' then query = Store[query] end
+
+	if transaction then
+		assert(type(query) == 'table', ('A table was expected for the transaction (received %s)'):format(query))
+	else
+		assert(type(query) == 'string', ('A string was expected for the query (received %s)'):format(query))
+	end
+
+	if cb then assert(type(cb) == 'function', ('A callback function was expected (received %s)'):format(cb)) end
+
+	local type = parameters and type(parameters)
+	if type and type ~= 'table' and type ~= 'function' then
+		assert(nil, ('A %s was expected, but instead received %s'):format(cb and 'table' or 'function', parameters))
+	end
+	return query, parameters, cb
+end
+
+local oxmysql = exports.oxmysql
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return table result
+---returns array of matching rows or result data
+function MySQL.execute(query, parameters, cb)
+	oxmysql:execute(safeArgs(query, parameters, cb))
+end
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return table result
+---returns table containing key value pairs
+function MySQL.single(query, parameters, cb)
+	oxmysql:single(safeArgs(query, parameters, cb))
+end
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return integer|string
+---returns value of the first column of a single row
+function MySQL.scalar(query, parameters, cb)
+	oxmysql:scalar(safeArgs(query, parameters, cb))
+end
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return integer result
+---returns number of rows updated by the executed query
+function MySQL.update(query, parameters, cb)
+	oxmysql:update(safeArgs(query, parameters, cb))
+end
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return table result
+---returns the last inserted id
+function MySQL.insert(query, parameters, cb)
+	oxmysql:insert(safeArgs(query, parameters, cb))
+end
+
+---@param queries table
+---@param parameters? table|function
+---@param cb? function
+---@return boolean result successful transaction
+function MySQL.transaction(queries, parameters, cb)
+	oxmysql:transaction(safeArgs(queries, parameters, cb, true))
+end
+
+---@param query string
+---@param parameters? table|function
+---@param cb? function
+---@return table results table containing the results for each query executed
+function MySQL.prepare(query, parameters, cb)
+	oxmysql:prepare(safeArgs(query, parameters, cb))
+end
+
+---@param query string
+---@param parameters? table|function
+---@return table result
+---returns array of matching rows or result data
+function MySQL.executeSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:execute(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param query string
+---@param parameters? table|function
+---@return table result
+---returns table containing key value pairs
+function MySQL.singleSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:single(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param query string
+---@param parameters? table|function
+---@return integer|string
+---returns value of the first column of a single row
+function MySQL.scalarSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:scalar(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param query string
+---@param parameters? table|function
+---@return integer result
+---returns number of rows updated by the executed query
+function MySQL.updateSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:update(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param query string
+---@param parameters? table|function
+---@return table result
+---returns the last inserted id
+function MySQL.insertSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:insert(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param queries table
+---@param parameters? table|function
+---@return boolean result successful transaction
+function MySQL.transactionSync(queries, parameters)
+	queries, parameters = safeArgs(queries, parameters, false, true)
+	oxmysql:transaction(queries, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+---@param query string
+---@param parameters? table|function
+---@return table results table containing the results for each query executed
+function MySQL.prepareSync(query, parameters)
+	query, parameters = safeArgs(query, parameters)
+	local promise = promise.new()
+	oxmysql:prepare(query, parameters, function(result)
+		promise:resolve(result)
+	end)
+	return Citizen.Await(promise)
+end
+
+return MySQL
\ No newline at end of file