-
Notifications
You must be signed in to change notification settings - Fork 101
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Moved MySQL data provider to main repo, revised for provider changes. F…
- Loading branch information
Matt Stevens
committed
Aug 3, 2014
1 parent
d9481fc
commit cf5406f
Showing
1 changed file
with
270 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,270 @@ | ||
| --[[ | ||
| PointShop MySQL Adapter by _Undefined | ||
| Usage: | ||
| First, make sure you have the MySQLOO module installed from: | ||
| http://www.facepunch.com/showthread.php?t=1220537 | ||
| Installation instructions are in that thread. | ||
| Then configure your MySQL details below and import the following tables into your database: | ||
| DROP TABLE IF EXISTS `pointshop_data`; | ||
| CREATE TABLE `pointshop_data` ( | ||
| `uniqueid` varchar(30) NOT NULL, | ||
| `points` int(32) NOT NULL, | ||
| `items` text NOT NULL, | ||
| PRIMARY KEY (`uniqueid`) | ||
| ) ENGINE=MyISAM DEFAULT CHARSET=latin1 | ||
| MAKE SURE YOU ALLOW REMOTE ACCESS TO YOUR DATABASE FROM YOUR GMOD SERVERS IP ADDRESS. | ||
| If you're upgrading from the old version, run the following SQL before starting your server and then remove the old tables (pointshop_points and pointshop_items): | ||
| INSERT INTO `pointshop_data` SELECT `pointshop_points`.`uniqueid`, `points`, `items` FROM `pointshop_points` INNER JOIN `pointshop_items` ON `pointshop_items`.`uniqueid` = `pointshop_points`.`uniqueid` | ||
| Once configured, change PS.Config.DataProvider = 'pdata' to PS.Config.DataProvider = 'mysql' in pointshop's sh_config.lua. | ||
| ]]-- | ||
|
|
||
| -- config, change these to match your setup | ||
|
|
||
| local mysql_hostname = 'localhost' -- Your MySQL server address. | ||
| local mysql_username = 'root' -- Your MySQL username. | ||
| local mysql_password = '' -- Your MySQL password. | ||
| local mysql_database = 'pointshop' -- Your MySQL database. | ||
| local mysql_port = 3306 -- Your MySQL port. Most likely is 3306. | ||
|
|
||
| -- end config, don't change anything below unless you know what you're doing | ||
|
|
||
| require('mysqloo') | ||
|
|
||
| local shouldmysql = false | ||
|
|
||
| local db = mysqloo.connect(mysql_hostname, mysql_username, mysql_password, mysql_database, mysql_port) | ||
|
|
||
| function db:onConnected() | ||
| MsgN('PointShop MySQL: Connected!') | ||
| shouldmysql = true | ||
| end | ||
|
|
||
| function db:onConnectionFailed(err) | ||
| MsgN('PointShop MySQL: Connection Failed, please check your settings: ' .. err) | ||
| end | ||
|
|
||
| db:connect() | ||
|
|
||
| function PROVIDER:GetData(ply, callback) | ||
| if not shouldmysql then self:GetFallback():GetData(ply, callback) end | ||
|
|
||
| local qs = [[ | ||
| SELECT * | ||
| FROM `pointshop_data` | ||
| WHERE uniqueid = '%s' | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID()) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onSuccess(data) | ||
| if #data > 0 then | ||
| local row = data[1] | ||
|
|
||
| local points = row.points or 0 | ||
| local items = util.JSONToTable(row.items or '{}') | ||
|
|
||
| callback(points, items) | ||
| else | ||
| callback(0, {}) | ||
| end | ||
| end | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| callback(0, {}) | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:SetPoints(ply, points) | ||
| if not shouldmysql then self:GetFallback():SetPoints(ply, points) end | ||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '%s', '[]') | ||
| ON DUPLICATE KEY UPDATE | ||
| points = VALUES(points) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), points or 0) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:GivePoints(ply, points) | ||
| if not shouldmysql then self:GetFallback():GivePoints(ply, points) end | ||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '%s', '[]') | ||
| ON DUPLICATE KEY UPDATE | ||
| points = points + VALUES(points) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), points or 0) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:TakePoints(ply, points) | ||
| if not shouldmysql then self:GetFallback():TakePoints(ply, points) end | ||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '%s', '[]') | ||
| ON DUPLICATE KEY UPDATE | ||
| points = points - VALUES(points) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), points or 0) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:SaveItem(ply, item_id, data) | ||
| self:GiveItem(ply, item_id, data) | ||
| end | ||
|
|
||
| function PROVIDER:GiveItem(ply, item_id, data) | ||
| if not shouldmysql then self:GetFallback():GiveItem(ply, item_id, data) end | ||
| local tmp = table.Copy(ply.PS_Items) | ||
| tmp[item_id] = data | ||
|
|
||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '0', '%s') | ||
| ON DUPLICATE KEY UPDATE | ||
| items = VALUES(items) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), db:escape(util.TableToJSON(tmp))) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:TakeItem(ply, item_id) | ||
| if not shouldmysql then self:GetFallback():TakeItem(ply, item_id) end | ||
| local tmp = table.Copy(ply.PS_Items) | ||
| tmp[item_id] = nil | ||
|
|
||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '0', '%s') | ||
| ON DUPLICATE KEY UPDATE | ||
| items = VALUES(items) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), db:escape(util.TableToJSON(tmp))) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end | ||
|
|
||
| function PROVIDER:SetData(ply, points, items) | ||
| if not shouldmysql then self:GetFallback():SetData(ply, points, items) end | ||
| local qs = [[ | ||
| INSERT INTO `pointshop_data` (uniqueid, points, items) | ||
| VALUES ('%s', '%s', '%s') | ||
| ON DUPLICATE KEY UPDATE | ||
| points = VALUES(points), | ||
| items = VALUES(items) | ||
| ]] | ||
| qs = string.format(qs, ply:UniqueID(), points or 0, db:escape(util.TableToJSON(items))) | ||
| local q = db:query(qs) | ||
|
|
||
| function q:onError(err, sql) | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| db:connect() | ||
| db:wait() | ||
| if db:status() ~= mysqloo.DATABASE_CONNECTED then | ||
| ErrorNoHalt("Re-connection to database server failed.") | ||
| return | ||
| end | ||
| end | ||
| MsgN('PointShop MySQL: Query Failed: ' .. err .. ' (' .. sql .. ')') | ||
| q:start() | ||
| end | ||
|
|
||
| q:start() | ||
| end |