XaBerr/JATE

<?php
  jRequire("../JException/JException.php");
  jRequire("../JConfig/JConfig.php");
  jRequire("../Connection/Connection.php");
  trait Query {
    public $connection;
    public $currentConnection;
    public function __construct() {
      $this->connection = [];
      $this->currentConnection = null;
    }
    public function addConnection( $_path, $_name = "default" ) {
      if(!is_string($_path))
        throw new JException("Parameter must be a string.", 1);
      try {
        $jConfig = new JConfig($_path);
        if($jConfig->enable) {
          $connection = new Connection($jConfig);
          $this->addConnectionMan($connection, $_name);
        }
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
    }
    public function addConnectionMan( $_connection, $_name = "default") {
      if(!is_object($_connection) || !is_a($_connection, "Connection"))
        throw new JException("Parameter must be a Connection object.", 1);
      try {
        $this->connection["$_name"] = $_connection;
        $this->currentConnection = $_connection;
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
    }
    public function setConnection( $_name = "default" ) {
      if(!is_string($_name))
        throw new JException("Parameter must be a string.", 1);
      if(!isset($this->connection["$_name"]))
        throw new JException("This connection name does not exist.", 1);
      $this->currentConnection = $this->connection["$_name"];
    }
    public function query( $_query ) {
      if(!is_string($_query))
        throw new JException("Parameter must be a string.", 1);
      if($this->currentConnection == null)
        throw new JException("No connection selected.", 1);
      try {
        $temp = $this->currentConnection->database->query($_query);
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
      return $temp;
    }
    public function queryInsert( $_query ) {
      if(!is_string($_query))
        throw new JException("Parameter must be a string.", 1);
      if($this->currentConnection == null)
        throw new JException("No connection selected.", 1);
      try {
        $temp = $this->currentConnection->database->queryInsert($_query);
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
      return $temp;
    }
    public function queryFetch( $_query ) {
      if(!is_string($_query))
        throw new JException("Parameter must be a string.", 1);
      if($this->currentConnection == null)
        throw new JException("No connection selected.", 1);
      try {
        $temp = $this->currentConnection->database->queryFetch($_query);
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
      return $temp;
    }
    public function queryArray( $_query ) {
      if(!is_string($_query))
        throw new JException("Parameter must be a string.", 1);
      if($this->currentConnection == null)
        throw new JException("No connection selected.", 1);
      try {
        $temp = $this->currentConnection->database->queryArray($_query);
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
      return $temp;
    }
    public function newTable( $_query ) {
      if(!is_string($_query))
        throw new JException("Parameter must be a string.", 1);
      if($this->currentConnection == null)
        throw new JException("No connection selected.", 1);
      try {
        $temp = $this->currentConnection->database->newTable($_query);
      } catch (Exception $e) {
        throw new JException($e->getMessage(), 1);
      }
      return $temp;
    }
  }
?>