Changeset 10 for trunk/Database.php

Timestamp:

Aug 28, 2019, 1:30:12 AM (5 years ago)

Author:

chronos

Message:

• Modified: Sync data for all runners and teams from official server.
• Modified: Optimize sync inserts with transaction.
• Added: Show table of all teams.

File:

• trunk/Database.php (modified) (9 diffs)

trunk/Database.php

@@ -2 +2 @@
 
 // Extended database class
-// Date: 2011-11-25
+// Date: 2016-01-11
+
+function microtime_float()
+{
+  list($usec, $sec) = explode(" ", microtime());
+  return ((float)$usec + (float)$sec);
+}
 
 class DatabaseResult
@@ -27 +33 @@
 class Database
 {
-  var $Prefix = '';
+  var $Prefix;
   var $Functions;
   var $Type;
   var $PDO;
-  var $Error = '';
+  var $Error;
   var $insert_id;
-  var $LastQuery = '';
+  var $LastQuery;
   var $ShowSQLError;
   var $ShowSQLQuery;
+  var $LogSQLQuery;
+  var $LogFile;
 
   function __construct()
   {
+    $this->Prefix = '';
+    $this->Functions = array('NOW()', 'CURDATE()', 'CURTIME()', 'UUID()');
     $this->Type = 'mysql';  // mysql, pgsql
+    $this->Error = '';
+    $this->LastQuery = '';
     $this->ShowSQLError = false;
     $this->ShowSQLQuery = false;
-    $this->Functions = array('NOW()', 'CURDATE()', 'CURTIME()', 'UUID()');
-  }
+    $this->LogSQLQuery = false;
+    $this->LogFile = dirname(__FILE__).'/../../Query.log';
+  }
+ 
 
   function Connect($Host, $User, $Password, $Database)
@@ -77 +91 @@
   function query($Query)
   {
-    if(!$this->Connected()) throw new Exception('Not connected to database');
+    if(!$this->Connected()) throw new Exception(T('Not connected to database'));
+    if(($this->ShowSQLQuery == true) or ($this->LogSQLQuery == true)) $QueryStartTime = microtime_float();
     $this->LastQuery = $Query;
+    //echo('a'.$this->ShowSQLQuery.'<'.$QueryStartTime.', '.microtime_float());
+    if(($this->ShowSQLQuery == true) or ($this->LogSQLQuery == true))
+      $Duration = ' ; '.round(microtime_float() - $QueryStartTime, 4). ' s';
+    if($this->LogSQLQuery == true)
+      file_put_contents($this->LogFile, $Query.$Duration."\n", FILE_APPEND);
     if($this->ShowSQLQuery == true)
-      echo('<div style="border-bottom-width: 1px; border-bottom-style: solid; padding-bottom: 3px; padding-top: 3px; font-size: 12px; font-family: Arial;">'.$Query.'</div>'."\n");
+      echo('<div style="border-bottom-width: 1px; border-bottom-style: solid; '.
+      'padding-bottom: 3px; padding-top: 3px; font-size: 12px; font-family: Arial;">'.$Query.$Duration.'</div>'."\n");
     $Result = new DatabaseResult();
     $Result->PDOStatement = $this->PDO->query($Query);
@@ -88 +109 @@
       $this->insert_id = $this->PDO->lastInsertId();
     } else
-    {
+    {     
       $this->Error = $this->PDO->errorInfo();
       $this->Error = $this->Error[2];
@@ -110 +131 @@
   function insert($Table, $Data)
   {
+    $this->query($this->GetInsert($Table, $Data));
+    $this->insert_id = $this->PDO->lastInsertId();
+  }
+  
+  function GetInsert($Table, $Data)
+  {
     $Name = '';
     $Values = '';
@@ -124 +151 @@
     $Name = substr($Name, 1);
     $Values = substr($Values, 1);
-    $this->query('INSERT INTO `'.$this->Prefix.$Table.'` ('.$Name.') VALUES('.$Values.')');
-    $this->insert_id = $this->PDO->lastInsertId();
+    return('INSERT INTO `'.$this->Prefix.$Table.'` ('.$Name.') VALUES('.$Values.')');
   }
 
   function update($Table, $Condition, $Data)
+  {
+    $this->query($this->GetUpdate($Table, $Condition, $Data));
+  }
+  
+  function GetUpdate($Table, $Condition, $Data)
   {
     $Values = '';
@@ -141 +172 @@
     }
     $Values = substr($Values, 2);
-    $this->query('UPDATE `'.$this->Prefix.$Table.'` SET '.$Values.' WHERE ('.$Condition.')');
+    return('UPDATE `'.$this->Prefix.$Table.'` SET '.$Values.' WHERE ('.$Condition.')');
   }
 
@@ -175 +206 @@
   }
 
+  function quote($Text)
+  {
+    return($this->PDO->quote($Text));
+  }
+
   public function __sleep()
   {
@@ -182 +218 @@
   public function __wakeup()
   {
+  }
+  
+  public function Transaction($Queries)
+  {
+      $this->PDO->beginTransaction();
+      foreach ($Queries as $Query)
+      {
+        $Statement = $this->PDO->prepare($Query);
+        $Statement->execute();
+      }          
+      $this->PDO->commit();
   }
 }