DataBase接続クラス

db_connect.md

#DataBase接続クラス

$dbServer = 'localhost';
$dbUser = 'root';
$dbPass = 'root';
$dbName = 'dtb_test';

class DB
{
	/*
	* コンストラクタ
	*
	* @var host:ホスト
	* @var user:ユーザー
	* @var pass:パス
	* @var db:データーベース名
	*/
	function __construct($dbServer,$dbUser,$dbPass,$dbName){
		$this->host = $dbServer;
		$this->user = $dbUser;
		$this->pass = $dbPass;
		$this->db = $dbName;
		$this->dsn = "mysql:dbname=$dbName;$host=$host";
	}

	/*
	* 配列で値を取得する
	*
	* @param String
	* @return array
	*/
	public function get_result_array($sql){
		try{
			$pdo = new PDO ($this->dsn, $this->user, $this->pass, array(
			PDO::MYSQL_ATTR_INIT_COMMAND => "SET CHARACTER SET 'utf8'"));
			$stmt = $pdo->prepare($sql);
			$stmt->execute();
			$data = $stmt->fetchAll(PDO::FETCH_ASSOC);
			return $data;
		} catch(PDOException $e) {
			echo "接続できませんでした<br />";
			echo h($e->getMessage());
		}
	}

	/*
	* オブジェクトで値を取得する
	*
	* @param String
	* @return Object
	*/
	public function get_result_object($sql){
		try{
			$pdo = new PDO ($this->dsn, $this->user, $this->pass, array(
			PDO::MYSQL_ATTR_INIT_COMMAND => "SET CHARACTER SET 'utf8'"));
			$stmt = $pdo->prepare($sql);
			$stmt->execute();
			$data = $stmt->fetchAll(PDO::FETCH_CLASS);
			return $data;
		} catch(PDOException $e) {
			echo "接続できませんでした<br />";
			echo h($e->getMessage());
		}
	}
}

$db_connect = new DB($dbServer,$dbUser,$dbPass,$dbName);
$sql = "SELECT * FROM trn_test";
$result = $db_connect->get_result_array($sql);
var_dump($result);
$result = $db_connect->get_result_object($sql);
var_dump($result);