Update 'src/DDLWrapper/Wrapper.php'
This commit is contained in:
@@ -3,6 +3,7 @@
|
|||||||
namespace DDLWrapper;
|
namespace DDLWrapper;
|
||||||
|
|
||||||
use DDLWrapper\Db\Table as Table;
|
use DDLWrapper\Db\Table as Table;
|
||||||
|
|
||||||
use DDLWrapper\Db\Adapter\PostgresAdapter;
|
use DDLWrapper\Db\Adapter\PostgresAdapter;
|
||||||
use DDLWrapper\Db\Adapter\MysqlAdapter;
|
use DDLWrapper\Db\Adapter\MysqlAdapter;
|
||||||
use DDLWrapper\Db\Adapter\SQLiteAdapter;
|
use DDLWrapper\Db\Adapter\SQLiteAdapter;
|
||||||
@@ -13,6 +14,7 @@ class Wrapper{
|
|||||||
private static $_instance;
|
private static $_instance;
|
||||||
|
|
||||||
public $_adapter;
|
public $_adapter;
|
||||||
|
public $_driver;
|
||||||
|
|
||||||
function __construct(){ }
|
function __construct(){ }
|
||||||
|
|
||||||
@@ -34,13 +36,16 @@ class Wrapper{
|
|||||||
|
|
||||||
public static function set_driver(\PDO $driver){
|
public static function set_driver(\PDO $driver){
|
||||||
$instance = self::getInstance();
|
$instance = self::getInstance();
|
||||||
|
$instance->_driver = $driver;
|
||||||
|
|
||||||
switch ($driver->driver){
|
switch ($driver->getAttribute(\PDO::ATTR_DRIVER_NAME)){
|
||||||
case 'sqlite':
|
case 'sqlite':
|
||||||
$instance->_adapter = new SQLiteAdapter();
|
$instance->_adapter = new SQLiteAdapter();
|
||||||
$instance-> _adapter->setConnection($driver);
|
$instance-> _adapter->setConnection($driver);
|
||||||
break;
|
break;
|
||||||
case 'pgsql':
|
case 'pgsql':
|
||||||
|
$instance->_adapter = new PostgresAdapter();
|
||||||
|
$instance->_adapter->setConnection($driver);
|
||||||
break;
|
break;
|
||||||
case 'mysql':
|
case 'mysql':
|
||||||
break;
|
break;
|
||||||
@@ -59,8 +64,15 @@ class Wrapper{
|
|||||||
$instance = self::getInstance();
|
$instance = self::getInstance();
|
||||||
$instance->_adapter->beginTransaction();
|
$instance->_adapter->beginTransaction();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static function commit(){
|
public static function commit(){
|
||||||
$instance = self::getInstance();
|
$instance = self::getInstance();
|
||||||
$instance->_adapter->commitTransaction();
|
$instance->_adapter->commitTransaction();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static function exec($sql){
|
||||||
|
$instance = self::getInstance();
|
||||||
|
$instance->_driver->exec($sql);
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user