mysql|数据|数据库
自己写着玩的，代码没有测试，不过觉得思路不错，如果能够加上部分异常处理的功能，应该比较帅了，支持PHP4/PHP5，恩，虽然没有ADOdb或者PEAR::DB强，不错一般应用应该不错，恩。
喜欢的就自己拿去用吧，自己随便改，呵呵，也欢迎提意见。（注释遵循PHPDoc的标准，便于生成手册）
注意：代码未经测试，出现问题可要自己负责哇，呵呵。
//==========================================
// 文件: SimpleDB.class.php
// 程序: MySQL数据库操作类
// 作者: heiyeluren
//==========================================
class SimpleDB
{
/**
* 接続識別子
* @var resource
*/
var $dbLink;
/**
* データベースクエリステートメント
* @var string
*/
var $dbSql;
/**
* クエリ結果
* @var リソース
*/
var $dbResult;
/ **
* クエリレコードセット
* @var array
*/
var $dbRecord;
/**
* データベース文字セット
* @var string
*/
var $dbCharset = 'GBK';
/**
* データベース結果セットの抽出方法
* @var int
*/
var $fetchMode = MYSQL_ASSOC;
/**
* ログ保存パス
* @var 文字列
*/
var $logPath = '/tmp/mysql_log';
/**
* 失敗した SQL クエリの SQL ログを記録するかどうか、デフォルトは false です
* @var bool
*/
var $isLog = false;
/**
* SQL クエリエラーが発生したときにエラーを表示してスクリプトの実行を終了するかどうか、デフォルトは true です
*
* @var bool
*/
var $isError = true;
//--------------------------
// 内部インターフェース
//--------------- ---------------
/**
*コンストラクター
*
* @param string $ db_host connect into Host
* @param string $ db_user connectユーザー
* @param string $ db_passwd database password ? 接続、デフォルトは
* @return SimpleDB
*/
function SimpleDB($db_host, $db_user, $db_passwd, $db_name, $is_pconnect=false){
$this- >connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect);
}
/**
* データベースに接続します
*
* @param string $db_host データベースのホストアドレス (例: localhost、または localhost:3306)
* @param string $db_user データベースに接続するユーザー
* @param string $db_passwd ユーザーのパスワード
* @param string $db_name データベース名
* @param boo $is_pconnect 長い接続を使用するかどうか
* @return resource 接続リソースの識別子を返します
*/
function connect($db_host, $db_user, $db_passwd, $db_name, $is_pconnect) ){
if ($is_pconnect){
return $this->dbLink = @mysql_pconnect($db_host, $db_user, $db_passwd);
}
$this->dbLink = @mysql_connect($db_host, $db_user、 $db_passwd);
@mysql_select_db($db_name, $this->dbLink);
$mysql_version = $this->getOne("SELECT VERSION()");
if ($this->dbCharset!=' ' && preg_match("/^(5.|4.1)/", $mysql_version)){
$this->query("SET NAMES '$this->dbCharset'", $this->dbLink);
}
return $this->dbLink;
}
/**
* データベース接続を閉じます
*
* @return bool 接続が正常に閉じられたかどうか
*/
function disconnect(){
$ret = @mysql_close($this->dbLink);
$this->dbLink = null;
return $ret;
}
/**
* 设置查询结果返回数据类型
*
* @param int $modeType 设置查询结果返回设置,1为关联索引和数字所有都有,2为使用关联索引,3为使用数字索引
*/
function setFetchMode($modeType){
switch ($modeType){
case 1: //数字索引和关联索引都有
$this->fetchMode = MYSQL_BOTH;
break;
case 2: //使用关联索引
$this->fetchMode = MYSQL_ASSOC;
break;
case 3: //使用数字索引
$this->fetchMode = MYSQL_NUM;
break;
default://缺省使用关联索引
$this->fetchMode = MYSQL_ASSOC;
}
}
/**
* 设置数据库客户端提取结果集的字符编码
*
* @param string $charset 编码的字符串,比如 UTF8,GBK之类的,缺省是GBK
*/
function setCharset($charset){
if ($charset != ''){
$this->dbCharset = $charset;
}
}
/**
* 设置日志存储路径
*
* @param string $log_path 日志路径,该必须是可写的
*/
function setLogPath($log_path){
if ($log_path != ''){
$this->logPath = $log_path;
}
}
/**
* 写SQL执行日志
*
* @param string $sql 查询的SQL语句
* @param string $file 当前执行查询的文件
*/
function writeLog($sql, $file){
if (!file_exists($this->logPath)){
@mkdir($this->logPath);
}
$log_file = $this->logPath ."/mysql_".date("Y-m-d").".log";
$log_msg = "[".date("Y-m-d H:i:s")."] - ".$file.": ".$sql." ";
error_log($log_msg, 3, $log_file);
}
/**
* 显示上依次SQL执行错误的错误信息
*/
function showError(){
$errMessage = "MySQL query error ". mysql_errno($this->dbLink) .": ". mysql_error($this->dbLink);
die($errMessage);
}
/**
* 返回MySQL的版本信息
*
* @return string Mysql的版本
*/
function getVersion(){
return $this->getOne("SELECT VERSION()");
}
/**
* 查询操作的底层接口
*
* @param string $sql 要执行查询的SQL语句
* @return bool 执行成功返回true,失败返回false
*/
function query($sql){
$this->dbSql = $sql;
$this->dbResult = null;
$this->dbResult = @mysql_query($sql, $this->dbLink);
if ($this->dbResult === false){
if ($this->isLog){
$this->writeLog($sql, __FILE__);
}
if ($this->isError){
$this->showError();
}
return false;
}
return true;
}
//--------------------------
// データ获取接口
//----------- ---------------
/**
* SQL 実行のすべての結果セット (2 次元配列) を取得します
*
* @param string $sql クエリを実行する必要がある SQL ステートメント
* @return クエリ結果の 2 次元配列を正常に返します。失敗した場合は false
*/
function getAll($sql){
if (!$this->query($sql)){
return false;
}
$this->dbRecord = array();
while ($row = @mysql_fetch_array($this->dbResult, $this->fetchMode)) {
$this->dbRecord[] = $row;
}
@mysql_free_result($this->dbResult);
if (!is_array($this->dbRecord) || empty($this->dbRecord)){
return false;
}
return $this->dbRecord;
}
/**
*単一の行レコード（1次元配列）を取得します
*
* @param string $ sql実行する必要があるsqlステートメント
* @return*/
function getRow($sql){
if (!$this->query($sql)){
return false;
}
$this->dbRecord = array();
$this->dbRecord = @mysql_fetch_array($this->dbResult, $this->fetchMode);
@mysql_free_result($this->dbResult) ;
if (!is_array($this->dbRecord) || empty($this->dbRecord)){
return false;
}
return $this->dbRecord;
}
/**
* データの列 (一次元配列) を取得します
1 次元配列を返します抽出された結果レコードの場合、失敗した場合は false
を返します*/
function getCol($sql, $field=''){
if (!$this->query($sql)){
return false;
}
$this->dbRecord = array( );
while($row = @mysql_fetch_array($this->dbResult, $this->fetchMode)){
if (trim($field) == ''){
$this->dbRecord[] = current($row);
} else {
$this->dbRecord[] = $row[$field];
}
}
@mysql_free_result($this-> dbResult);
if (!is_array( $this->dbRecord) || empty($this->dbRecord)){
return false;
}
return $this->dbRecord;
}
/**
* 获取一个数据(当条数组)
*
* @param string $sql 需要执行查询的SQL
* @return 成功返回获取的一个数据,失败返回false
*/
function getOne($sql, $field=''){
if (!$this->query($sql)){
return false;
}
$this->dbRecord = array();
$row = @mysql_fetch_array($this->dbResult, $this->fetchMode);
@mysql_free_result($this->dbResult);
if (!is_array($row) || empty($row)){
return false;
}
if (trim($field) != ''){
$this->dbRecord = $row[$field];
}else{
$this->dbRecord = current($row);
}
return $this->dbRecord;
}
/**
*さまざまな条件を指定するレコードを取得します。レコードの条件付きステートメントを除く、デフォルトを除く制限を除く、デフォルトは空です。 getRow を呼び出すか getAll を呼び出すか、デフォルトは false、つまり getAll を呼び出します)
false
*/
function getRecord($table, $field='*', $where='', $order='', $limit='', $single=false){
$ sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= トリム($order)!='' ? " $order で注文" : $order;
$sql .= トリム($limit)!='' ? " LIMIT $limit" : $limit;
if ($single){
return $this->getRow($sql);
}
return $this->getAll($sql);
}
/* *
* さまざまな条件を指すレコードを取得します (getRecored と同様)
*
* @param string $table テーブル名 (アクセスするデータテーブル)
* @param string $field フィールド (取得するフィールド)
* @param 文字列$where 条件 (レコードを取得するための条件文、WHERE を除く、デフォルトは空) * @param array $order_arr 配列のソート (形式は array('id'=>true) と似ており、ID 順にソートされます、array('id'=>false)、IDで逆順にソートされます)
* @param array $limit_arr データを抽出するための制限配列()
* @returnunknown
*/
function getSpecifyRecord($table, $field='*', $where='', $order_arr=array(), $limit_arr=array()){
$sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
if (is_array($order_arr) && !empty($order_arr)){
$arr_key = key($order_arr);
$sql .= " ORDER BY $arr_key " 。 （$ order_arr [$ arr_key]？ "asc"： "desc"）;
} if（is_array（$ limit_arr）&&！empty（$ limit_arr））{
$ start_post = intval（$ limit_arr）;
$offset = intval(array_shift($limit_arr));
$sql .= " LIMIT $start_post,$offset";
}
return $this->getAll($sql);
}
/**
* 指定されたレコード数を取得します
*
* @param string $table テーブル名
* @param int $start_pos 記録を開始します
* @param int $offset offset
Param String $ where 条件 (レコード取得の条件文) 、where を除く、デフォルトは空です)
* @Param String $ Order Sort (どのフィールドがソートされるか、order by を除く、デフォルトは空です)
@Return は、含まれている記録された 2 次元配列を含めるように正常に戻り、失敗した場合は false
を返します*/
function getLimitRecord($table, $start_pos, $offset, $field='*', $where='', $oder=''){
$sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= トリム($order)!='' ? " $order で注文" : $order;
$sql .= "LIMIT $start_pos,$offset";
return $this->getAll($sql);
}
/**
* ソートされたレコードを取得します
*
* @param string $table テーブル名
* @param string $order_field ソートする必要があるフィールド (id など)
* @param string $order_method ソート方法 (1 は order、 2 は逆順、デフォルトは 1)
* @param string $field 抽出するフィールド (デフォルトは *、すべてのフィールド)
* @param string $where 条件 (WHERE を除く、デフォルトのレコードを取得するための条件文)は空です)
* @ Param String $ Limit Limited Records (抽出する必要があるレコードの数、Limit を除く、デフォルトは空)
* @Return は記録されたレコードの 2 次元配列を正常に返しましたが、false を返すのに失敗しました
*/
function getOrderRecord($table, $order_field, $order_method =1, $field='*', $where='', $limit=''){
//$order_method の值は 1 顺序、$order_method 值は 2 2 は逆順列
$sql = "SELECT $field FROM $table";
$sql .= トリム($where)!='' ? " WHERE $where " : $where;
$sql .= " ORDER BY $order_field " 。 ( $order_method==1 ? "ASC" : "DESC");
$sql .= トリム($limit)!='' ? " LIMIT $limit" : $limit;
return $this->getAll($sql);
}
/**
*ページングクエリ（クエリの記録の数を制限）*/
function limitQuery($sql, $start_pos, $offset){
$ start_pos = intval($start_pos);
$offset = intval($offset);
$sql = $sql 。 " LIMIT $start_pos,$offset ";
return $this->getAll($sql);
}
//---------- -----
// 無数据返操作
//--------------------------
/**
*/
関数execute（$ sql）{
if（！$ this-＆gt; query（$ sql））{
false; <= 0){
return false;
}
return true;
}
/**作 * 自動実行操作 (Insert/Update 操作の場合)
*
* @param String $ Table テーブル名
@param Array $ Field_array フィールド配列 (配列内のキーはフィールド名に相当し、配列の値は配列 ( 'id' => 100, 'user' => 'heiyeluren') に似た値
* @param int $mode 操作を実行するモード (挿入操作か更新操作か、1 は挿入操作 Insert、2 は更新操作 Update)
* @param string $where 更新操作の場合は、WHERE 条件を追加できます
* @return bool 実行が成功した場合は true、失敗した場合は false を返します
*/
function autoExecute($table, $field_array, $mode, $where=''){
もし($table=='' || !is_array($field_array) || empty($field_array)){
return false; $ sql = rtrim ($ sql, ',');
if ($ mode == 2 && $ where! = '') {
$ sql = "どこ $ どこ";
//---------------
// その他のデータ関連の操作
//--- -------- ---------------
– – − −評判-‑ ‑ ‑ ‑ ‑ – – − − −評判@@ l_insert_id（$ this-＆gt; dblink）{！$ this-＆gt; dbresult）
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
