php Mysql クラス。学習して慣れるために参照できます。

复制代码代码如下:

class Mysql
{
private $conn;
プライベート $host;
プライベート $ユーザー名;
プライベート $パスワード;
プライベート $dbname;
プライベート $pconnect;
プライベート $charset;

public function __construct(array $params = null)
{
if (!empty($params)) {
foreach ($params as $k => $v) {
$this->$k = $v;
}
}
}

public function connect()
{
$fun = $this->pconnect ? 'mysql_pconnect' : 'mysql_connect';
$this->conn = $fun($this->ホスト, $this->ユーザー名, $this->パスワード);
$this->conn && $this->query('set names ' . $this->charset);
$this->conn && mysql_select_db($this->dbname, $this->conn);
}

public function getInstance()
{
return $this->conn;
}

public function query($sql)
{
return mysql_query($sql, $this->conn);
}

public function fetchOne($sql)
{
$data = $this->fetchRow($sql);
$data[0] を返す;
}

パブリック関数 fetchCol($sql)
{
$tmp = $this->fetchAll($sql, MYSQL_NUM);
foreach ($tmp as $v) {
$data[] = $v[0];
}
}

public function fetchRow($sql)
{
$result = $this->query($sql);
$data = mysql_fetch_row($result);
mysql_free_result($result);
$data を返します;
}

public function fetchAssoc($sql)
{
$result = $this->query($sql);
$data = mysql_fetch_assoc($result);
mysql_free_result($result);
$data を返します;
}

パブリック関数 fetchAll($sql, $type = MYSQL_ASSOC)
{
$result = $this->query($sql);
while ($tmp = mysql_fetch_array($result, $type)) {
$data[] = $tmp;
}
$data を返します。
}

public function fetchPairs($sql)
{
$result = $this->query($sql);
while ($tmp = mysql_fetch_row($result)) {
$data[$tmp[0]] = $tmp[1];
}
$data を返します。

}

public function insert($table, array $bind)
{
$cols = array();
$vals = array();
foreach ($bind as $col => $val) {
$cols[] = $col;
$vals[] = $val;
unset($bind[$col]);
}
$sql = "INSERT INTO "
。 $テーブル
。 ' (`' . implode('`, `', $cols) . '`) '
。 'VALUES ('' . implode('', '', $vals) . '')';

$stmt = $this->query($sql, $this->conn);
$result = $this->affectedRows();
$result を返す;
}

public function getLastInsertId()
{
return mysql_insert_id($this->conn);
}

public functionaffectedRows()
{
return mysql_affected_rows($this->conn);
}

public function update($table, array $bind, $where = '')
{
$set = array();
foreach ($bind as $col => $val) {
$set[] = '`' . $col . "` = '" 。 $val 。 "";
}

$sql = "UPDATE `"
。 $テーブル
。 「セット」。 implode(', ', $set)
。 (($where) ? " WHERE $where" : '');

$stmt = $this->query($sql, array_values($bind));
$result = $this->affectedRows();
$result を返す;
}

public function delete($table, $where = '')
{
/**
* DELETE ステートメントを作成します
*/
$sql = "DELETE FROM "
。 $テーブル
。 (($where) ? " WHERE $where" : '');

/**
* ステートメントを実行し、影響を受ける行の数を返します
*/
$stmt = $this->query($sql);
$result = $stmt ? mysql_affected_rows($this->conn) : $stmt;
$result を返す;
}

public function close()
{
$this->conn && mysql_close($this->conn);
}
}
?>