@@ -25,7 +25,7 @@ class Db{
 	 */
 	private $engine;
 	private $params;
-	private $_engine_name="pdo_mysql";
+	private $_engine_name="mysql";
 	private $_allow_engines=array(
 			"mysql","mysqli",
 			"pdo_mysql","pdo_sqlite","pdo_cubrid",
@@ -346,12 +346,12 @@ private function __query($sql, $retry=false){
 		}
 		//Connect
 		if(!isset(Db::$_globals[$this->_key])){
-			if($this->_engine_name == "mysql" || $this->_engine_name =="mysqli"){
-				require_once(SLIGHTPHP_PLUGINS_DIR."/db/DbMysqli.php");
-				$this->engine = new \SlightPHP\DbMysqli($this->params);
-			}else{
+			if(strpos($this->_engine_name ,"pdo_") === 0){
 				require_once(SLIGHTPHP_PLUGINS_DIR."/db/DbPDO.php");
 				$this->engine = new \SlightPHP\DbPDO($this->params);
+			}else{
+				require_once(SLIGHTPHP_PLUGINS_DIR."/db/DbMysqli.php");
+				$this->engine = new \SlightPHP\DbMysqli($this->params);
 			}
 			$this->engine->init($this->params);
 			if($this->engine->connect()===false){
 
@@ -63,24 +63,25 @@ public function connect(){
 		$tmp = explode("_",$this->_engine);
 		$driver =$tmp[1];
 		try{
+			$options = array(
+				\PDO::ATTR_PERSISTENT => $this->_persistent,
+				\PDO::ATTR_STRINGIFY_FETCHES => false,
+				\PDO::ATTR_EMULATE_PREPARES => false,
+				\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
+			);
+			if(!empty($this->_charset)){
+				$options[\PDO::MYSQL_ATTR_INIT_COMMAND]="SET CHARACTER SET {$this->_charset}, NAMES {$this->_charset}";
+			}
 			$this->_pdo = new \PDO(
 				$driver .":dbname=".$this->_database.";host=".$this->_host.";port=".$this->_port,
 				$this->_user,
 				$this->_password,
-				array(
-					\PDO::ATTR_PERSISTENT => $this->_persistent,
-					\PDO::ATTR_STRINGIFY_FETCHES => false,
-					\PDO::ATTR_EMULATE_PREPARES => false,
-					\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
-				)
+				$options,
 			);
 		}catch(\PDOException  $e){
 			trigger_error("CONNECT DATABASE ERROR ( ".$e->getMessage()." ) ",E_USER_WARNING);
 			return false;
 		}
-		if(!empty($this->_charset)){
-			$this->_pdo->exec("SET NAMES ".$this->_charset);
-		}
 		return true;
 	}
 	public function query($sql){