<?php

class db{

private $dbConfig = [

'db' => 'mysql',

'ホスト' => 'localhost',

'ポート' => '3306',

'データベース名' =>  'one',

'user' => 'root',

'パスワード' => '1234',//

'文字セット' => 'utf'

];

public $insertId = null;

public $num = 0;

private static $instance = null;

private $conn = null;

プライベート関数 __construct($params){

$this->dbConfig = array_merge($this->dbConfig,$params);

$this->conncet();

}

プライベート関数__clone(){

}

パブリック関数getInstance(){

if(!self::$instanceinstanceofself){

self::$instance = new self();

}

return self::$instance;

}

public function connect(){

try{

$dsn = "{$this->dbConfig['db']}:{$this ->dbConfig['host']};

ポート = {$this->dbConfig['port']};

文字セット = {$this->dbConfig['charset']}";

$this->conn = new pdo($dsn,$this->dbConfig['user'],$this->dbConfig['password']);

}

catch(PDOExecption $e){

die("データベース库连接失败".$e->getMessage());

}

}

// データテーブルの書き込み操作を完了します 新增 更新 删除

// 返される影響响の记录結果新しい增主键id

public function exec($sql){

$num = $this->conn->exec($sql);

// 如果有影响的记录

if($num>0){

// 結果が新しい操作の初期化新しい主键IDのプロパティ

if(null !==$this->conn->lastInsertId()){

$this ->insertId = $this->conn->lastInsertId();

}

$this->num = $rum;// 返される受影响の记录

}else{

$error = $this->conn->errorInfo(); //最後の操作の错误情報【0】错误代码【2】错误情報

print '操作失敗'.$error[0].':'.$error[1].': '.$error[2];

}

}

//获取单条查询情報

public function fetch ($sql )

{

return $this->conn->query ($sql)->fetch(PDO::FETCH_ASSOC);

}

public function fetchALL($sql){

return $this->conn->query($sql)->fetch( PDO::FETCH_ASSOC);

}

}