検索
ホームページphp教程php手册phplibのDBクラスの拡張版

phplibのDBクラスの拡張版

Jun 13, 2016 pm 12:30 PM
pephp気分が悪いのためにコード使用強化するコピー開発するバージョン親切私自身の

コードをコピー コードは次のとおりです:


/*********************************** ************************************************* * *******************************
独自の開発を促進するため、次のような巨大なツールを使用したくないADODB と PEAR::DB、
PHPLib DB クラスに基づいて使用されます。PEAR::DB クラスを参照してください。カプセル化された DB クラスはシンプルで使いやすく、非常に便利です。
MySQL は有効です

[データベースに接続]

//データベース処理クラス ファイルを含めます
include_once("database.inc.php"); // ローカルデータベース設定
define("DB_HOST", "localhost"); //データベースサーバー
define("DB_USER_NAME", "root") //データベースユーザー名
define("DB_USER_PASS"); , " "); //パスワード
define("DB_DATABASE", "test"); //データベース

//ローカルデータベースに接続します
$db = new DB_Sql(); >$db ->connect(DB_DATABASE, DB_HOST, DB_USER_NAME, DB_USER_PASS);

[使用法]

//すべてのレコードを取得します
$sql = "SELECT * FROM table1";
$all_record = $db->get_all($sql);

//1 つ取得します
$sql = "SELECT * FROM table1 WHERE id = '1'"; one_row = $db->get_one($sql);

//ページ クエリ、20 レコードを抽出
$sql = "SELECT * FROM table1"; ; limit_query($sql, $start=0, $offset=20, $order="ORDER BY id DESC");

//指定された数のレコードを抽出します
$sql = "SELECT * FROM table1 ";
$limit_record = $db->get_limit($sql,10);

//レコード数をカウントし、すべてのタイプの生徒をカウントします
$count = $db -> count("table1", "id", "type = 'student'");

//レコードを挿入します
$info_array = array(
"name" => "heiyeluren" 、
"タイプ" => "学生"、
"性別" => "男の子"
) $db- >insert("table1", $info_array);

//レコードを更新します
$info_array = array(
"name" => "heiyeluren",
"タイプ" => "先生",
"年齢" => "男の子"
); "table1" , $info_array, "name = 'heiyeluren'");

//レコードを削除します
$db->delete("table1", "name = 'heiyeluren'"); 🎜>
//結果セットなしで SQL を実行します
$db->e​​xecute("DELETE FROM table1 WHERE name = 'heiyeluren'");

******** ** *********************************************** *** *********************************************/

/**
* ファイル:database.inc.php
* 説明:データベース操作クラス
* 説明:このライブラリは、PHPLib DB ライブラリをコアとして使用し、いくつかの実用的なメソッドを追加しています。詳細についてはコメントを参照してください。
*/

class DB_Sql
{

/* public: 接続パラメータ */
var $Host = ""; 🎜> var $ Database = "";
var $Password = "";

/* public: 設定パラメータ */
1; ## 自動 mysql_free_result() の場合は 1 に設定します。
var $Debug = 0; ## メッセージのデバッグには 1 に設定します。
var $Halt_On_Error = "yes" ## "yes"; )、"no " (エラーを無視します)、"report" (エラーを無視しますが、警告を吐きます)
var $PConnect = 0; ## 永続的なデータベース接続を使用するには 1 に設定します
var $Seq_Table = " db_sequence";

/* public: 結果の配列と現在の行番号 */
var $Record = array();
var $Row;

/* public: 現在エラー番号とエラーテキスト */
var $Errno = 0;
var $Error = "";

/* public: これは CVS リビジョンではありません。 🎜> var $ type = "mysql"
//var $revision = "1.2";  /* private: リンクと クエリ ハンドル */
var $Link_ID = 0;
var $Query_ID = 0;

var $locked = false;      ## ロックがある間は true に設定

/* public: constructor */
function DB_Sql() {
$this->query($query);
}

/* 公開: いくつかの 簡単な レポート */
function link_id() {
return $this->Link_ID;
}

function query_id() {
return $this->Query_ID;
}

/* public: 接続管理 */
function connect($Database = "", $Host = "", $User = "", $Password = "") {
/* デフォルトの処理 */
if ("" == $Database)
$Database = $this->Database;

if ("" == $Host)
$Host = $this->Host;

if ("" == $User)
$User = $this->User;

if ("" == $Password)
$Password = $this->パスワード;


/* 接続を確立し、データベースを選択します */
if ( 0 == $this->Link_ID ) {

if(!$this->PConnect) {
$this->Link_ID = mysql_connect($Host, $User, $Password);
} else {
$this->Link_ID = mysql_pconnect($Host, $User, $Password); 
}
if (!$this->Link_ID) {
$this->halt("connect($Host, $User, $Password) が失敗しました。");
0 を返す;
}

if (!@mysql_select_db($Database,$this->Link_ID)) {
$this->halt("データベースを使用できません".$Database);
0 を返す;
}
}

return $this->Link_ID;
}

/* public: クエリ結果を破棄 */
function free() {
@mysql_free_result($this->Query_ID);
$this->Query_ID = 0;
}

/* public: クエリを実行 */
function query($Query_String) {
/* 空のクエリは PHP4 でチョークするため、使用しないでください。 */
if ($Query_String == "")
/* クエリなしでクラスを呼び出す場合、空のクエリ文字列がコンストラクターから渡されます。
* 状況
* 次のような場合: 「$db = new DB_Sql_Subclass;」
*/
0 を返す;

if (!$this->connect()) {
return 0; /* 私たちはそれについてすでに connect() で苦情を申し立てました。 */
};

# 新しいクエリ、以前の結果は破棄されます。
if ($this->Query_ID) {
$this->free();
}

if ($this->Debug)
printf("Debug: query = %s
n", $Query_String);

$this->Query_ID = @mysql_query($Query_String,$this->Link_ID);
$this->行 = 0;
$this->Errno = mysql_errno();
$this->Error = mysql_error();
if (!$this->Query_ID) {
$this->halt("無効な SQL: ".$Query_String);
}

# 失敗した場合は nada を返します。 それはいいです。
return $this->Query_ID;
}

/* public: walk result set */
function next_record() {
if (!$this->Query_ID) {
$this->halt (「保留中のクエリなしで next_record が呼び出されました。」);
0 を返す;
}

$this->Record = @mysql_fetch_array($this->Query_ID);
$this->行 = 1;
$this->Errno = mysql_errno();
$this->エラー = mysql_error();

$stat = is_array($this->Record);
if (!$stat && $this->Auto_Free) {
$this->free();
}
$stat を返す;
}

/* public: position in result set */
function seek($pos = 0) {
$status = @mysql_data_seek($this->Query_ID, $pos );
if ($status)
$this->Row = $pos;
else {
$this->halt("seek($pos) 失敗: 結果は ".$this->num_rows()." 行数です。");

/* その日を救おうとする中途半端な試みですが、
* ただし、これが文書化されている、または
* 望ましい動作であるとは考えないでください。
*/
@mysql_data_seek($this->Query_ID, $this->num_rows());
$this->Row = $this->num_rows();
0 を返す;
}

1 を返します。
}

/* public: table locking */
function lock($table, $mode = "write") {
$query = "lock tables ";
if(is_array($table)) {
while(list($key,$value) = each($table)) {
// テキストキーは「read」、「read local」、 「書き込み」、「低優先度の書き込み」
if(is_int($key)) $key = $mode;
if(strpos($value, ",")) {
$query .= str_replace(",", " $key, ", $value) 。 " $key, ";
} else {
$query .= "$value $key, ";
}
}
$query = substr($query, 0, -2);
} elseif(strpos($table, ",")) {
$query .= str_replace(",", " $mode, ", $table) 。 " $モード";
} else {
$query .= "$table $mode";
}
if(!$this->query($query)) {
$this->halt("lock() 失敗しました。");
false を返します。
}
$this->locked = true;
true を返します。
}

function unlock() {

// 潜在的なループを避けるためにロック解除前に設定します
$this->locked = false;

if(!$this->query("unlock tables")) {
$this->halt("unlock() failed.");
false を返します。
}
true を返します。
}

/* public: 結果の評価 (サイズ, 幅) */
function affected_rows() {
return @mysql_affected_rows($this->Link_ID);
}

function num_rows() {
return @mysql_num_rows($this->Query_ID);
}

function num_fields() {
return @mysql_num_fields($this->Query_ID);
}

/* public: 省略記法 */
function nf() {
return $this->num_rows();
}

function np() {
print $this->num_rows();
}

function f($Name) {
if (isset($this->Record[$Name])) {
return $this->Record[$Name] ];
}
}

function p($Name) {
if (isset($this->Record[$Name])) {
print $this->レコード[$Name];
}
}

/* public: sequence numbers */
function nextid($seq_name) {
/* 現在のロックがない場合は、ロック シーケンス テーブル */
if(!$this->locked) {
if($this->lock($this->Seq_Table)) {
$locked = true;
} else {
$this->halt("ロックできません".$this->Seq_Table." - 作成されましたか?");
0 を返す;
}
}

/* get sequence number and increment */
$q = sprintf("select nextid from %s where seq_name = '%s'",
$ this->Seq_Table、
$seq_name);
if(!$this->query($q)) {
$this->halt('nextid でクエリが失敗しました: '.$q);
0 を返す;
}

/* 現在の値はありません。値を作成します*/
if(!$this->next_record()) {
$currentid = 0;
$q = sprintf("insert into %s values('%s', %s)",
$this->Seq_Table,
$seq_name,
$currentid);
if(!$this->query($q)) {
$this->halt('nextid でクエリが失敗しました: '.$q);
0 を返す;
}
} else {
$currentid = $this->f("nextid");
}
$nextid = $currentid 1;
$q = sprintf("update %s set nextid = '%s' where seq_name = '%s'",
$this->Seq_Table,
$nextid,
$seq_name) ;
if(!$this->query($q)) {
$this->halt('nextid でクエリが失敗しました: '.$q);
0 を返す;
}

/*nextid() がシーケンス テーブルをロックしている場合は、ロックを解除します*/
if($locked) {
$this->unlock();
}

return $nextid;
}

/* public: return table metadata */
function metadata($table = "", $full = false) {
$count = 0;
$id = 0;
$res = array();

/*
* Table との互換性の問題により、 metadata() の動作
* が変更されました。
* $full に応じて、メタデータは次の 値を返します:
*
* - full は false (デフォルト):
* $result[]:
* [0]["table "] テーブル名
* [0]["name"] フィールド名
* [0]["type"] フィールドの種類
* [0]["len"] フィールドの長さ
* [0]["flags"] フィールド フラグ
*
* - full is true
* $result[]:
* ["num_fields"] メタデータ レコードの数
* [0 ]["テーブル"] テーブル名
* [0]["名前"] フィールド名
* [0]["タイプ"] フィールドタイプ
* [0]["len"] フィールドの長さ
* [0]["flags"] フィールドフラグ
* ["メタ"][フィールド名] 「フィールド名」という名前のフィールドのインデックス
* この最後の フィールドは、フィールドがある場合に使用できます。名前はありますが、インデックスはありません。
* テスト: if (isset($result['meta']['myfield'])) { ...
*/

// $table が指定されていない場合は、クエリ
// 結果
if ($table) {
$this->connect(); を処理しています。
$id = @mysql_list_fields($this->Database, $table);
if (!$id) {
$this->halt("メタデータクエリが失敗しました。");
false を返します。
}
} else {
$id = $this->Query_ID; 
if (!$id) {
$this->halt("クエリが指定されていません。");
false を返します。
}
}

$count = @mysql_num_fields($id);

// この IF はパフォーマンスを考慮して作成されました(1 つの if は $count if よりも高速です)
if (!$full) {
for ($i=0; $i $res[$i]["table"] = @mysql_field_table ($id, $i);
$res[$i]["name"] = @mysql_field_name ($id, $i);
$res[$i]["type"] = @mysql_field_type ($id, $i);
$res[$i]["len"] = @mysql_field_len ($id, $i);
$res[$i]["flags"] = @mysql_field_flags ($id, $i);
}
} else { // full
$res["num_fields"]= $count;

for ($i=0; $i $res[$i]["table"] = @mysql_field_table ($id, $i);
$res[$i]["name"] = @mysql_field_name ($id, $i);
$res[$i]["type"] = @mysql_field_type ($id, $i);
$res[$i]["len"] = @mysql_field_len ($id, $i);
$res[$i]["flags"] = @mysql_field_flags ($id, $i);
$res["meta"][$res[$i]["name"]] = $i;
}
}

// テーブルで呼び出された場合にのみ、結果を解放します
if ($table) {
@mysql_free_result($id);
}
$res を返す;
}

/* public: 利用可能なテーブル名を検索 */
function table_names() {
$this->connect();
$h = @mysql_query("show tables", $this->Link_ID);
$i = 0;
while ($info = @mysql_fetch_row($h)) {
$return[$i]["table_name"] = $info[0];
$return[$i]["tablespace_name"] = $this->データベース;
$return[$i]["データベース"] = $this->データベース;
$i ;
}

@mysql_free_result($h);
return $return;
}

/* private: error handling */
function halt($msg) {
$this->Error = @mysql_error($this->Link_ID);
$this->Errno = @mysql_errno($this->Link_ID);

if ($this->locked) {
$this->unlock();
}

if ($this->Halt_On_Error == "no")
return;

$this->haltmsg($msg);

if ($this->Halt_On_Error != "レポート")
die("セッションが停止しました。");
}

function haltmsg($msg) {
printf("データベースエラー: %s
n", $msg);
printf("MySQL エラー: %s (%s)
n",
$this->Errno,
$this->Error) ;
}


//----------------------------------
// 模块: 自定関数
// 機能: 部分使用的データ库処理方法
// 作成者: heiyeluren
// 期間: 2005-12-26
//--- -----------------------------

/**
* メソッド:execute($sql)
* 機能:主に結果セットを返さない SQL に対して SQL ステートメントを実行します
* パラメータ: $sql 実行する必要がある SQL ステートメント。例:execute("DELETE FROM table1 WHERE id = '1'")
* 戻り値: 更新が成功した場合は True、更新が失敗した場合は False を返します
*/
関数 実行($sql)
{
if (empty($sql))
{
$this->error("無効なパラメータ");
}
if (!$this->query($sql))
{
return false;
}
true を返します。
}

/**
* メソッド: get_all($sql)
* 関数: SQL 実行のすべてのレコードを取得
* パラメーター: $sql 実行する必要がある SQL。例: get_all("SELECT * FROM Table1" )
* 戻り値: すべてのクエリ結果を含む 2 次元配列を返します
*/
function get_all($sql)
{
$this->query($sql);
$result_array = array();
while($this->next_record())
{

$result_array[] = $this->Record;
}
if (count($result_array) {
return 0;
}
return $result_array;
}

/**
* メソッド: get_one($sql)
* 関数: SQL 実行の記録を取得します
* パラメーター: $sql 実行される SQL、例: get_one("SELECT * FROM Table1 WHERE id = '1 '")
* 戻り値: クエリ結果を含む 1 次元配列を返します
*/
function get_one($sql)
{
$this->query($sql);
if (!$this->next_record())
{
return 0;
}
return $this->レコード;
}

/**
* メソッド: get_limit($sql, $limit)
* 関数: SQL 実行のために指定されたレコード数を取得します
* パラメーター:
* $sql 実行する必要がある SQL。例: SELECT * FROM Table1
* $limit 制限する必要があるレコードの数
* たとえば、10 件のレコードを取得する必要がある場合、get_limit("SELECT * FROM Table1", 10); > *
* 戻り値: すべてのクエリ結果を含む戻り値
の 2 次元配列*/
function get_limit($sql, $limit)
{
$this->query($sql);
$result_array = array();
for ($i=0; $inext_record(); $i )
{
$result_array[] = $this->Record;
}
if (count($result_array) {
return 0;
}
return $result_array;
}

/**
* メソッド:limit_query($sql, $start=0, $offset=20, $order="")
* 関数: ページング SQL 実行の指定レコード数を取得
* パラメーター:
* $sql 実行する必要がある SQL。例: SELECT * FROM Table1
* $start レコードの開始番号、デフォルトは 0
* $offset レコードのオフセット、デフォルトは 20
* $order ソート方法。デフォルトは空です。例: ORDER BY id DESC
* たとえば、0 から 10 までのレコードを取得し、ID 番号でソートする必要があります。 get_limit("SELECT * FROM Table1", 0, 10 , "ORDER BY id DESC");
*
* 戻り値: すべてのクエリ結果を含む 2 次元配列
を返します。*/
function limit_query($sql, $start=0, $offset=20, $order="")
{
$sql = $sql ." $order LIMIT $start,$offset";
$this->query($sql);
$result = array();
while($this->next_record())
{
$result[] = $this->Record;
}
if (count($result) {
return 0;
}
$result を返す;
}

/**
* メソッド: count($table,$field="*", $where="")
* 関数: 統計テーブル内のデータの総数
* パラメーター:
* $table統計が必要です テーブル名
* $field カウントする必要があるフィールド、デフォルトは *
* $where 条件ステートメント、デフォルトは空
* たとえば、20 歳未満のすべてのユーザーをカウントしますID に従って、 count("user_table" , "id", "user_age *
* 戻り値: 統計結果の数を返します
*/
関数 count($table,$field="*", $where="")
{
$sql = (empty($どこ) ? "SELECT COUNT($field) FROM $table" : "SELECT COUNT($field) FROM $table WHERE $where");
$result = $this->get_one($sql);
if (!is_array($result))
{
return 0;
}
return $result[0];
}

/**
* メソッド: insert($table,$dataArray)
* 関数: テーブルにレコードを挿入
* パラメーター:
* $table 挿入するテーブルの名前
* $dataArray 必須 フィールドと値の配列を挿入します。キーはフィールド名、値はフィールド値です。例: array("user_name"=>"Zhang San", "user_age"=>"20 years) old");
* 例: ユーザー Zhang San を挿入、年齢は 20、insert("users", array("user_name"=>"Zhang San", "user_age"=>"20 歳") )
*
* Return: レコードの挿入が成功した場合は True、失敗した場合は False を返します
*/
function insert($table,$dataArray)
{
if (!is_array($dataArray) || count($ dataArray) {
$this->error("無効なパラメータ");
}
while(list($key,$val) = each($dataArray))
{
$field .= "$key,";
$value .= "'$val',";
}
$field = substr($field, 0, -1);
$value = substr($value, 0, -1);
$sql = 「$table ($field) VALUES ($value)に挿入」;
if (!$this->query($sql))
{
return false;
}
true を返します。
}

/**
* メソッド: update($talbe, $dataArray, $where)
* 関数: レコードを更新
* パラメーター:
* $table 更新する必要があるテーブルの名前
* $dataArray が必要です。 フィールドと値の配列を更新します。 キーはフィールド名、値はフィールド値です。 例: array("user_name"=>"Zhang San", "user_age"=>") 20 歳");
* $where 条件文
* たとえば、Zhang San という名前のユーザーは Li Si に更新され、年齢は 21 歳になります
* update("users", array("user_name"=>"張三", "user_age"=> ;"20 歳"), "user_name='張三'")
*
* 戻り値: 更新が有効な場合は True成功しました。更新が失敗した場合は False
*/
function update($talbe, $dataArray, $where)
{
if (!is_array($dataArray) || count($dataArray) {
$this->error("無効なパラメータ");
}
while(list($key,$val) = each($dataArray))
{
$value .= "$key = '$val',";
}
$value = substr($value, 0, -1);
$sql = "UPDATE $talbe SET $value WHERE $where";
if (!$this->query($sql))
{
return false;
}
true を返します。
}

/**
* メソッド: delete($table, $where)
* 関数: レコードの削除
* パラメーター:
* $table レコードを削除する必要があるテーブルの名前
* $where レコードを削除する必要があります 条件文
* たとえば、Zhang San という名前のユーザーを削除する場合は、delete("users", "user_name='Zhang San'")
*
* Return: 更新が成功した場合は True を返し、失敗した場合は False を返します
*/
function delete($table, $where)
{
if (empty($where))
{
$this ->error("無効なパラメータ");
}
$sql = "$table WHERE $where から削除します";
if (!$this->query($sql))
{
return false;
}
true を返します。
}

/**
* メソッド: error($msg="")
* 機能: エラーメッセージを表示した後、スクリプトを中止します
* パラメータ: $msg 表示するエラーメッセージ
* 戻り値: なし
*/
関数 error($msg="")
{
echo "エラー: $ msgn
n";
exit();
}

/**
* メソッド: get_insert_id()
* 関数: 最後に挿入された ID を取得します
* パラメーター: パラメーターなし
* 戻り値: 終了が成功した場合は ID、失敗した場合は 0 を返します
*/
function get_insert_id()
{
return mysql_insert_id($this->Link_ID);
}

/**
* メソッド: close()
* 関数: 現在のデータベース接続を閉じる
* パラメータ: パラメータなし
* 戻り値: 成功した場合は true、失敗した場合は false を返します
*/
function close()
{
return mysql_close($this->Link_ID);
}
}
?>

声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強力な PHP 統合開発環境

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

EditPlus 中国語クラック版

EditPlus 中国語クラック版

サイズが小さく、構文の強調表示、コード プロンプト機能はサポートされていません

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser は、オンライン試験を安全に受験するための安全なブラウザ環境です。このソフトウェアは、あらゆるコンピュータを安全なワークステーションに変えます。あらゆるユーティリティへのアクセスを制御し、学生が無許可のリソースを使用するのを防ぎます。

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール