INIT

Author: millsoft

.gitignore

@@ -0,0 +1 @@
+.idea

README.md

@@ -0,0 +1,18 @@
+##SQL Tunnel Soap Server/Client for PHP
+
+### What is this?
+Not every hoster allows to connect directly to MYSQL but allows a direct Web connection (Port 80). This script is the middleman between your app and some mysql database.
+ 
+ ### How To use?
+ See tests/testsoap.php for an example how to use this
+ 
+ 
+ ### Thats all?
+ yeah, for now thats all.. I don't want to make it complicated but I might add more features to it later. For now this is what I needed in one of my projects.
+ 
+ 
+ --
+ 
+ ***Have a nice day ;)***
+ 
+ `Michael` 

sql.php

@@ -0,0 +1,135 @@
+<?php
+
+/**
+ * Class SQL
+ * @Author Michael Milawski
+ */
+
+
+class SQL
+{
+    public $config = array();
+    public $wokeUp = "no";
+    private $DB = null;
+    private $isConnected = false;
+
+    public function getConfig ()
+    {
+        return $_SESSION[ 'config' ];
+    }
+
+    public function setConfig ($config)
+    {
+        $_SESSION[ 'config' ] = $config;
+        $this->config = $config;
+    }
+
+
+    /**
+     * Execute an SQL query
+     *
+     * @param $sql
+     * @param array $params
+     *
+     * @return array|bool
+     */
+    public function query ($sql, $params = array())
+    {
+        if (!$this->isConnected) {
+
+            $connected = $this->connect();
+
+            if (is_array($connected)) {
+                return $connected;
+            }
+
+            if (!$connected === true) {
+                return $connected;
+            }
+        }
+
+        try {
+            //connect as appropriate as above
+            $stmt = $this->DB->prepare($sql);
+            $stmt->execute($params);
+            $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
+
+            $re = array(
+                "status" => "OK",
+                "data"   => $results,
+                "count"  => $stmt->rowCount(),
+            );
+
+            //get count of rows when used limits
+            if (stripos($sql, "SQL_CALC_FOUND_ROWS") !== false) {
+                $cnt_stmt = $this->DB->prepare("SELECT FOUND_ROWS() as cnt");
+                $cnt_stmt->execute();
+                $cnt_res = $cnt_stmt->fetch(PDO::FETCH_ASSOC);
+
+                if (!empty($cnt_res) && isset($cnt_res[ 'cnt' ])) {
+                    $re[ 'FOUND_ROWS' ] = $cnt_res[ 'cnt' ];
+                }
+            }
+
+            return $re;
+
+        } catch (PDOException $ex) {
+            return array(
+                "status" => "ERROR",
+                "error"  => $ex->getMessage()
+            );
+
+        }
+    }
+
+
+    /**
+     * Connect to the database, config data is used from session
+     * @return array|bool
+     */
+    private function connect ()
+    {
+        extract($_SESSION[ 'config' ]);
+
+        $charset = isset($charset) ? $charset : "utf8mb4";
+        if (isset($port)) {
+            $host = $host . ":" . $port;
+        }
+
+        try {
+            $db = new PDO("mysql:host={$host};dbname={$dbname};charset={$charset}", $username, $password);
+            $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+            $db->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
+        } catch (PDOException $ex) {
+            return array(
+                "status" => "ERROR",
+                "error"  => $ex->getMessage()
+            );
+
+        }
+
+        $this->DB = $db;
+        $this->isConnected = true;
+
+        return true;
+    }
+}
+
+
+try {
+    session_start();
+    $myurl = "http://{$_SERVER['HTTP_HOST']}{$_SERVER['REQUEST_URI']}";
+
+    $server = new SOAPServer(
+        NULL,
+        array(
+            'uri' => $myurl
+        )
+    );
+
+    $server->setPersistence(SOAP_PERSISTENCE_SESSION);
+    $server->setClass('SQL');
+    $server->handle();
+} catch (SOAPFault $f) {
+    print $f->faultstring;
+}

tests/testsoap.php

@@ -0,0 +1,44 @@
+<?php
+
+/**
+ * Simple Test for the SOAP client
+ */
+
+
+/**
+ * @param $tunnel_url
+ * @param $config
+ *
+ * @return \SoapClient
+ */
+function getDbTunnel($tunnel_url, $config){
+
+    try {
+        $db = new SoapClient(null, array(
+            'location' => $tunnel_url,
+            'uri' => $tunnel_url,
+            'trace' => 1,
+            'compression' => SOAP_COMPRESSION_ACCEPT | SOAP_COMPRESSION_GZIP
+        ));
+
+        $db->setConfig($config);
+
+    } catch (SoapFault $fault) {
+        trigger_error("SOAP-Error: (Error No: {$fault->faultcode}, "
+                      . "Error: {$fault->faultstring})", E_USER_ERROR);
+    }
+    return $db;
+}
+
+$tunnel_url = "http://localhost/sqltunnel/sql.php";
+
+$config = array(
+    "host" => "YourHost",
+    "dbname" => "db",
+    "username" => "username",
+    "password" => "password",
+);
+
+$S = getDbTunnel($tunnel_url, $config);
+$data = $S->query("SELECT SQL_CALC_FOUND_ROWS id,name_en FROM events LIMIT 3");
+print_r($data);