aleajactaest/khanat-opennel-code
1
0
Fork 0
mirror of https://port.numenaute.org/aleajactaest/khanat-opennel-code.git synced 2024-11-11 17:59:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Syncing basics, need refactoring though

Browse source
This commit is contained in:
Quitta 2013-06-27 04:54:41 +02:00
parent c5965b4d10
commit ec074a3523
3 changed files with 73 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/sync.php Normal file
View file

@ -0,0 +1,65 @@
<?php
class Sync{
/**
*
* Function syncdata
*
* @takes Nothing
* @return array $values
*
* Info: Runs functions to finish syncing data when shard is offline
*
*/
static public function syncdata () {
global $LIBDBHOST;
global $LIBDBPORT;
global $LIBDBNAME;
global $LIBDBUSERNAME;
global $LIBDBPASSWORD;
global $SHARDDBHOST;
global $SHARDDBPORT;
global $SHARDDBNAME;
global $SHARDDBUSERNAME;
global $SHARDDBPASSWORD;
try {
$dbl = new PDO("mysql:host=$LIBDBHOST;port=$LIBDBPORT;dbname=$LIBDBNAME", $LIBDBUSERNAME, $LIBDBPASSWORD);
$dbl->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$statement = $dbl->prepare("SELECT * FROM ams_querycache");
$statement->execute();
$rows = $statement->fetchAll();
$dbs = new PDO("mysql:host=$SHARDDBHOST;port=$SHARDDBPORT;dbname=$SHARDDBNAME", $SHARDDBUSERNAME, $SHARDDBPASSWORD);
$dbs->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
foreach ($rows as $record) {
switch($record['type']) {
case 'createPermissions':
case 'user_edit':
case 'createUser':
$query = json_decode($record['query']);
//make connection with and put into shard db
$statement = $dbs->prepare("INSERT INTO user (Login, Password, Email) VALUES (?, ?, ?)");
$statement->execute($query);
$statement = $dbl->prepare("DELETE FROM ams_querycache WHERE SID=:SID");
$query = array('SID' => $record['SID']);
$statement->execute($query);
}
}
print('Syncing completed');
}
catch (PDOException $e) {
print('Something went wrong!');
print_r($e);
}
}
}

4
code/ryzom/tools/server/ryzom_ams/ams_lib/autoload/users.php
View file

@ -236,7 +236,7 @@ class Users{
return $salt;
}
function create_Server_User($params)
/*function create_Server_User($params)
{
try {
$hostname = 'localhost';
@ -254,7 +254,7 @@ class Users{
return "fail";
}
// createPermissions(array($login));
}
}*/
function createUser($values){

6
code/ryzom/tools/server/ryzom_ams/ams_lib/cron/sync_cron.php Normal file
View file

@ -0,0 +1,6 @@
<?php
require( '../libinclude.php' );
require( '../../www/config.php' );
Sync::syncdata();