mirrors/PocketMine-MP
1
0
Fork 0
mirror of https://github.com/pmmp/PocketMine-MP.git synced 2025-06-07 12:18:46 +00:00
Code Issues Projects Releases Wiki Activity

Faster SQLite

Browse Source
This commit is contained in:
Shoghi Cervantes Pueyo 2012-12-17 16:40:55 +01:00
parent ab3862446c
commit adb795be22
2 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
classes/ChunkParser.class.php
View File

@ -93,8 +93,8 @@ class ChunkParser{
} }
$chunk = ""; $chunk = "";
foreach($this->map[$X][$Z] as $section => $data){ foreach($this->map[$X][$Z] as $section => $data){
foreach($data as $r){ for($i = 0; $i < 256; ++$i){
$chunk .= $r; $chunk .= $data[$i];
} }
} }
return Utils::writeLInt(strlen($chunk)).$chunk; return Utils::writeLInt(strlen($chunk)).$chunk;

22
classes/PocketMinecraftServer.class.php
View File

@ -28,7 +28,7 @@ the Free Software Foundation, either version 3 of the License, or
require_once("classes/Session.class.php"); require_once("classes/Session.class.php");
class PocketMinecraftServer extends stdClass{ class PocketMinecraftServer extends stdClass{
var $seed, $protocol, $gamemode, $name, $maxClients, $clients, $eidCnt, $custom, $description, $motd, $timePerSecond, $responses, $spawn, $entities, $mapDir, $mapName, $map, $level, $tileEntities; var $preparedSQL, $seed, $protocol, $gamemode, $name, $maxClients, $clients, $eidCnt, $custom, $description, $motd, $timePerSecond, $responses, $spawn, $entities, $mapDir, $mapName, $map, $level, $tileEntities;
private $database, $interface, $evCnt, $handCnt, $events, $handlers, $version, $serverType, $lastTick; private $database, $interface, $evCnt, $handCnt, $events, $handlers, $version, $serverType, $lastTick;
function __construct($name, $gamemode = 1, $seed = false, $protocol = CURRENT_PROTOCOL, $port = 19132, $serverID = false, $version = CURRENT_VERSION){ function __construct($name, $gamemode = 1, $seed = false, $protocol = CURRENT_PROTOCOL, $port = 19132, $serverID = false, $version = CURRENT_VERSION){
$this->port = (int) $port; //19132 - 19135 $this->port = (int) $port; //19132 - 19135
@ -94,6 +94,7 @@ class PocketMinecraftServer extends stdClass{
} }
public function startDatabase(){ public function startDatabase(){
$this->preparedSQL = new stdClass();
$this->database = new SQLite3(":memory:"); $this->database = new SQLite3(":memory:");
$this->query("PRAGMA journal_mode = OFF;"); $this->query("PRAGMA journal_mode = OFF;");
$this->query("PRAGMA encoding = \"UTF-8\";"); $this->query("PRAGMA encoding = \"UTF-8\";");
@ -105,6 +106,10 @@ class PocketMinecraftServer extends stdClass{
$this->query("CREATE TABLE events (ID INTEGER PRIMARY KEY, name TEXT);"); $this->query("CREATE TABLE events (ID INTEGER PRIMARY KEY, name TEXT);");
$this->query("CREATE TABLE handlers (ID INTEGER PRIMARY KEY, name TEXT, priority NUMERIC);"); $this->query("CREATE TABLE handlers (ID INTEGER PRIMARY KEY, name TEXT, priority NUMERIC);");
$this->query("PRAGMA synchronous = OFF;"); $this->query("PRAGMA synchronous = OFF;");
$this->preparedSQL->selectHandlers = $this->database->prepare("SELECT ID FROM handlers WHERE name = ? ORDER BY priority DESC;");
$this->preparedSQL->selectEvents = $this->database->prepare("SELECT ID FROM events WHERE name = ?;");
$this->preparedSQL->selectActions = $this->database->prepare("SELECT ID,code,repeat FROM actions WHERE last <= (? - interval);");
$this->preparedSQL->updateActions = $this->database->prepare("UPDATE actions SET last = :time WHERE last <= (:time - interval);");
} }
public function query($sql, $fetch = false){ public function query($sql, $fetch = false){
@ -181,7 +186,8 @@ class PocketMinecraftServer extends stdClass{
} }
public function handle($event, &$data){ public function handle($event, &$data){
$handlers = $this->query("SELECT ID FROM handlers WHERE name = '$event' ORDER BY priority DESC;"); $this->preparedSQL->selectHandlers->bindValue(1, $event, SQLITE3_TEXT);
$handlers = $this->preparedSQL->selectHandlers->execute();
if($handlers === false or $handlers === true){ if($handlers === false or $handlers === true){
return $this->trigger($event, $data); return $this->trigger($event, $data);
} }
@ -401,7 +407,8 @@ class PocketMinecraftServer extends stdClass{
} }
public function trigger($event, $data = ""){ public function trigger($event, $data = ""){
$events = $this->query("SELECT ID FROM events WHERE name = '".$event."';"); $this->preparedSQL->selectEvents->bindValue(1, $event, SQLITE3_TEXT);
$events = $this->preparedSQL->selectEvents->execute();
if($events === false or $events === true){ if($events === false or $events === true){
return; return;
} }
@ -427,10 +434,10 @@ class PocketMinecraftServer extends stdClass{
console("[INTERNAL] Attached to action ".$microseconds, true, true, 3); console("[INTERNAL] Attached to action ".$microseconds, true, true, 3);
} }
public function tickerFunction(){ public function tickerFunction($time){
//actions that repeat every x time will go here //actions that repeat every x time will go here
$time = microtime(true); $this->preparedSQL->selectActions->bindValue(1, $time, SQLITE3_FLOAT);
$actions = $this->query("SELECT ID,code,repeat FROM actions WHERE last <= (".$time." - interval);"); $actions = $this->preparedSQL->selectActions->execute();
if($actions === false or $actions === true){ if($actions === false or $actions === true){
return; return;
} }
@ -440,7 +447,8 @@ class PocketMinecraftServer extends stdClass{
$this->query("DELETE FROM actions WHERE ID = ".$action["ID"].";"); $this->query("DELETE FROM actions WHERE ID = ".$action["ID"].";");
} }
} }
$this->query("UPDATE actions SET last = ".$time." WHERE last <= (".$time." - interval);"); $this->preparedSQL->updateActions->bindValue(":time", $time, SQLITE3_FLOAT);
$this->preparedSQL->updateActions->execute();
} }
public function event($event, $func, $in = false){ public function event($event, $func, $in = false){