この記事では主に、基本的なデータベース接続、追加、削除、変更、接続などを実現できる PHP の pdo ベースのデータベース操作クラスを紹介します。mysql、sqlserver、oracle などのデータベースの操作もサポートしています。必要な方はご利用ください。参照してください。
この記事の例では、PHP の pdo ベースのデータベース操作クラスについて説明します。参考までに皆さんに共有してください。詳細は以下の通りです:
仕事でsqlserverやoracleを操作する必要があるときにこのクラスを使用します。
<?php
class Pdodb{
protected $pdo;
protected $res;
protected $config;
/*构造函数*/
function __construct($config){
$this->Config = $config;
$this->connect();
}
/*数据库连接*/
public function connect(){
try {
$this->pdo= new PDO($this->Config['dsn'], $this->Config['username'], $this->Config['password']);//$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
$this->pdo->query("set names utf8");
}catch(Exception $e){
echo '数据库连接失败,详情: ' . $e->getMessage () . ' 请在配置文件中数据库连接信息';
exit ();
}
/*
if($this->Config['type']=='oracle'){
$this->pdo->query("set names {$this->Config['charset']};");
}else{
$this->pdo->query("set names {$this->Config['charset']};");
}
*/
//把结果序列化成stdClass
//$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
//自己写代码捕获Exception
//$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);//属性名 属性值 数组以关联数组返回
}
/*数据库关闭*/
public function close(){
$this->pdo = null;
}
//用于有记录结果返回的操作，特别是SELECT操作
public function query($sql,$return=false){
$res = $this->pdo->query($sql);
if($res){
$this->res = $res; // 未返回 return $this->res;
}
if($return){
return $res;
}
}
//主要是针对没有结果集合返回的操作，比如INSERT、UPDATE、DELETE等操作
public function exec($sql,$return=false){
$res = $this->pdo->exec($sql);
if($res){
$this->res = $res;
}
if($return){//返回操作是否成功 成功返回1 失败0
return $res;
}
}
//将$this->res以数组返回(全部返回)
public function fetchAll(){
return $this->res->fetchAll();
}
//将$this->res以数组返回(一条记录)
public function fetch(){
return $this->res->fetch();
}
//返回所有字段
public function fetchColumn(){
return $this->res->fetchColumn();
}
//返回最后插入的id
public function lastInsertId(){
return $this->res->lastInsertId();
}
//返回最后插入的id
public function lastInsertId2(){
return $this->pdo->lastInsertId();
}
/**
* 参数说明
* string/array $table 数据库表，两种传值模式
* 普通模式：
* 'tb_member, tb_money'
* 数组模式：
* array('tb_member', 'tb_money')
* string/array $fields 需要查询的数据库字段，允许为空，默认为查找全部，两种传值模式
* 普通模式：
* 'username, password'
* 数组模式：
* array('username', 'password')
* string/array $sqlwhere 查询条件，允许为空，两种传值模式
* 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询)：
* 'and type = 1 and username like "%os%"'
* 数组模式：
* array('type = 1', 'username like "%os%"')
* string $orderby 排序，默认为id倒序
*int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 返回多条记录
* 1 返回单条记录
* 2 返回行数
*/
public function select($table, $fields="*", $sqlwhere="", $orderby="", $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($fields)){
$fields = implode(',',$fields);
/*
if($this->Config['type']=='oracle'){
//$fields = implode(',',$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL
//$fields = implode(",'UTF8','ZHS16GBK') ,convert(",$fields);
//$fields="convert(".$fields.",'UTF8','ZHS16GBK')";
}else{
$fields = implode(',',$fields);
}
*/
}
if(is_array($sqlwhere)){
$sqlwhere = ' and '.implode(' and ', $sqlwhere);
}
//数据库操作
if($debug === 0){
if($mode === 2){ //统计
$this->query("select count(*) from $table where 1=1 $sqlwhere");
$return = $this->fetchColumn();
}else if($mode === 1){ //返回一条
$this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
$return = $this->fetch();
}else{
$this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
$return = $this->fetchAll();//如果 $this->res为空即sql语句错误 会提示Call to a member function fetchAll() on a non-object
}
return $return;
}else{
if($mode === 2){
echo "select count(*) from $table where 1=1 $sqlwhere";
}else if($mode === 1){
echo "select $fields from $table where 1=1 $sqlwhere $orderby";
}else{
echo "select $fields from $table where 1=1 $sqlwhere $orderby";
}
if($debug === 2){
exit;
}
}
}
/**
* 参数说明
* string/array $table 数据库表，两种传值模式
* 普通模式：
* 'tb_member, tb_money'
* 数组模式：
* array('tb_member', 'tb_money')
* string/array $set 需要插入的字段及内容，两种传值模式
* 普通模式：
* 'username = "test", type = 1, dt = now()'
* 数组模式：
* array('username = "test"', 'type = 1', 'dt = now()')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
* 2 返回最后一次插入记录的id
*/
public function oic_insert($table, $set, $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';$i=0;
foreach($set as $k=>$v){
$i++;
$s[$i]=$k;//,连接
$val[$i]=$v;
}
$sarr=implode(",",$s);//去掉最后一个,
//array_pop($sarr);
$set=implode("','",$val);////15221579236','张三','','2001','8','4','女','是
//$set = implode(', ', $set);
}
//数据库操作
if($debug === 0){
if($mode === 2){
$this->query("insert into $table ($sarr) values('".$set."')");
//$return = $this->lastInsertId();
}else if($mode === 1){
$this->exec("insert into $table ($sarr) values('".$set."')");
$return = $this->res;
}else{
$this->query("insert into $table ($sarr) values('".$set."')");
$return = NULL;
}
return $return;
}else{
echo "insert into $table ($sarr) values('".$set."')";
if($debug === 2){
exit;
}
}
}
public function insert($table, $set, $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';
foreach($set as $k=>$v){
$s.=$k."='".$v."',";//,连接
}
$sarr=explode(',',$s);//去掉最后一个,
array_pop($sarr);
$set=implode(',',$sarr);
//$set = implode(', ', $set);
}
//数据库操作
if($debug === 0){
if($mode === 2){
$this->query("insert into $table set $set");
$return = $this->pdo->lastInsertId();
}else if($mode === 1){
$this->exec("insert into $table set $set");
$return = $this->res;
}else{
$this->query("insert into $table set $set");
$return = NULL;
}
return $return;
}else{
echo "insert into $table set $set";
if($debug === 2){
exit;
}
}
}
/**
* 参数说明
* string $table 数据库表，两种传值模式
* 普通模式：
* 'tb_member, tb_money'
* 数组模式：
* array('tb_member', 'tb_money')
* string/array $set 需要更新的字段及内容，两种传值模式
* 普通模式：
* 'username = "test", type = 1, dt = now()'
* 数组模式：
* array('username = "test"', 'type = 1', 'dt = now()')
* string/array $sqlwhere 修改条件，允许为空，两种传值模式
* 普通模式：
* 'and type = 1 and username like "%os%"'
* 数组模式：
* array('type = 1', 'username like "%os%"')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
*/
public function update($table, $set, $sqlwhere="", $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';
foreach($set as $k=>$v){
$s.=$k."='".$v."',";
}
$sarr=explode(',',$s);//去掉最后一个,
array_pop($sarr);
$set=implode(',',$sarr);
//$set = implode(', ', $set);
}
if(is_array($sqlwhere)){
$sqlwhere = ' and '.implode(' and ', $sqlwhere);
}
//数据库操作
if($debug === 0){
if($mode === 1){
$this->exec("update $table set $set where 1=1 $sqlwhere");
$return = $this->res;
}else{
$this->query("update $table set $set where 1=1 $sqlwhere");
$return = true;
}
return $return;
}else{
echo "update $table set $set where 1=1 $sqlwhere";
if($debug === 2){
exit;
}
}
}
/**
* 参数说明
* string $table 数据库表
* string/array $sqlwhere 删除条件，允许为空，两种传值模式
* 普通模式：
* 'and type = 1 and username like "%os%"'
* 数组模式：
* array('type = 1', 'username like "%os%"')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
*/
public function delete($table, $sqlwhere="", $debug=0, $mode=0){
//参数处理
if(is_array($sqlwhere)){
$sqlwhere = ' and '.implode(' and ', $sqlwhere); //是字符串需自己加上and
}
//数据库操作
if($debug === 0){
if($mode === 1){
$this->exec("delete from $table where 1=1 $sqlwhere");
$return = $this->res;
}else{
$this->query("delete from $table where 1=1 $sqlwhere");
$return = NULL;
}
return $return;
}else{
echo "delete from $table where 1=1 $sqlwhere";
if($debug === 2){
exit;
}
}
}
}
/*
sqlserver 配置 extension=php_pdo_mssql.dll和extension=php_pdo_sqlsrv.dll 安装对应的 ntwdblib.dll
http://msdn.microsoft.com/en-us/library/cc296170.aspx 下载php版本对应的sqlsrv扩展
sqlserver 配置 odbc连接需开启extension=php_pdo_odbc.dll
*/
$mssql2008_config=array(
'dsn'=>'odbc:Driver={SQL Server};Server=192.168.1.60;Database=his',//数据库服务器地址
'username'=>'sa',
'password'=>'xxxxx',
);
$mssql=new Pdodb($mssql2008_config);
$sql="select * from
(
select row_number()over(order by tempcolumn)temprownumber,*
from (
select top 10 tempcolumn=0,a.*
from DA_GR_HBFS a
where 1=1
) t
) tt
where temprownumber>0";
$mssql->query($sql);
while($res=$mssql->fetch()){
$data[]=$res;
}
print_r($data);exit;
//mysql 操作
$msyql_config=array(
'dsn'=>'mysql:host=localhost;dbname=talk',
'username'=>'root',
'password'=>'123456'
);
$mysql=new PDO_DB($msyql_config);
$sql = 'SELECT user_id, user_name, nickname FROM et_users ';
$mysql->query($sql);
$data=$mysql->fetchAll();
print_r($data);exit;
//oracle 操作
$oci_config=array(
'dsn'=>'oci:dbname=orcl',
'username'=>'BAOCRM',
'password'=>'BAOCRM'
);
$oracle=new PDO_DB($oci_config);
//print_r($oracle);exit;//PDO_DB Object ( [pdo:protected] => PDO Object ( ) [res:protected] => [config:protected] => [Config] => Array ( [dsn] => oci:dbname=orcl [name] => PWACRM [password] => PWACRM ) )
$sql="select * from CUSTOMER_LEVEL t";
$oracle->query($sql);
$data=$oracle->fetchAll();
print_r($data);exit;
/*
Array
(
[0] => Array
(
[LEVEL_ID] => 1
[0] => 1
[LEVEL_NAME] => 普通会员
[1] => 普通会员
[LEVEL_DETAIL] => 普通会员
[2] => 普通会员
[SORT_NUMBER] => 15
[3] => 15
[CREATE_TIME] => 12-7月 -12
[4] => 12-7月 -12
[CREATE_BY] => 1
[5] => 1
[UPDATE_TIME] => 12-7月 -12
[6] => 12-7月 -12
[UPDATE_BY] => 1
[7] => 1
[STATE] => 正常
[8] => 正常
)
)*/
?>
関連する推奨事項:
PHPによって実装されたMySQLの読み書き分離操作PHPはフォームの繰り返し送信を防止する機能を実装します(トークン検証に基づいて)
以上がPDO に基づく PHP データベース操作クラス [mysql、sqlserver、oracle をサポート可能]の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
PHPの現在のステータス：Web開発動向を見てくださいApr 13, 2025 am 12:20 AMPHPは、現代のWeb開発、特にコンテンツ管理とeコマースプラットフォームで依然として重要です。 1）PHPには、LaravelやSymfonyなどの豊富なエコシステムと強力なフレームワークサポートがあります。 2）パフォーマンスの最適化は、Opcacheとnginxを通じて達成できます。 3）PHP8.0は、パフォーマンスを改善するためにJITコンパイラを導入します。 4）クラウドネイティブアプリケーションは、DockerおよびKubernetesを介して展開され、柔軟性とスケーラビリティを向上させます。
PHP対その他の言語：比較Apr 13, 2025 am 12:19 AMPHPは、特に迅速な開発や動的なコンテンツの処理に適していますが、データサイエンスとエンタープライズレベルのアプリケーションには良くありません。 Pythonと比較して、PHPはWeb開発においてより多くの利点がありますが、データサイエンスの分野ではPythonほど良くありません。 Javaと比較して、PHPはエンタープライズレベルのアプリケーションでより悪化しますが、Web開発により柔軟性があります。 JavaScriptと比較して、PHPはバックエンド開発により簡潔ですが、フロントエンド開発のJavaScriptほど良くありません。
PHP対Python：コア機能と機能Apr 13, 2025 am 12:16 AMPHPとPythonにはそれぞれ独自の利点があり、さまざまなシナリオに適しています。 1.PHPはWeb開発に適しており、組み込みのWebサーバーとRich Functionライブラリを提供します。 2。Pythonは、簡潔な構文と強力な標準ライブラリを備えたデータサイエンスと機械学習に適しています。選択するときは、プロジェクトの要件に基づいて決定する必要があります。
PHP：Web開発の重要な言語Apr 13, 2025 am 12:08 AMPHPは、サーバー側で広く使用されているスクリプト言語で、特にWeb開発に適しています。 1.PHPは、HTMLを埋め込み、HTTP要求と応答を処理し、さまざまなデータベースをサポートできます。 2.PHPは、ダイナミックWebコンテンツ、プロセスフォームデータ、アクセスデータベースなどを生成するために使用され、強力なコミュニティサポートとオープンソースリソースを備えています。 3。PHPは解釈された言語であり、実行プロセスには語彙分析、文法分析、編集、実行が含まれます。 4.PHPは、ユーザー登録システムなどの高度なアプリケーションについてMySQLと組み合わせることができます。 5。PHPをデバッグするときは、error_reporting（）やvar_dump（）などの関数を使用できます。 6. PHPコードを最適化して、キャッシュメカニズムを使用し、データベースクエリを最適化し、組み込み関数を使用します。 7
PHP：多くのウェブサイトの基礎Apr 13, 2025 am 12:07 AMPHPが多くのWebサイトよりも優先テクノロジースタックである理由には、その使いやすさ、強力なコミュニティサポート、広範な使用が含まれます。 1）初心者に適した学習と使用が簡単です。 2）巨大な開発者コミュニティと豊富なリソースを持っています。 3）WordPress、Drupal、その他のプラットフォームで広く使用されています。 4）Webサーバーとしっかりと統合して、開発の展開を簡素化します。
誇大広告を超えて：今日のPHPの役割の評価Apr 12, 2025 am 12:17 AMPHPは、特にWeb開発の分野で、最新のプログラミングで強力で広く使用されているツールのままです。 1）PHPは使いやすく、データベースとシームレスに統合されており、多くの開発者にとって最初の選択肢です。 2）動的コンテンツ生成とオブジェクト指向プログラミングをサポートし、Webサイトを迅速に作成および保守するのに適しています。 3）PHPのパフォーマンスは、データベースクエリをキャッシュおよび最適化することで改善でき、その広範なコミュニティと豊富なエコシステムにより、今日のテクノロジースタックでは依然として重要になります。
PHPの弱い参照は何ですか、そしていつ有用ですか？Apr 12, 2025 am 12:13 AMPHPでは、弱い参照クラスを通じて弱い参照が実装され、ガベージコレクターがオブジェクトの回収を妨げません。弱い参照は、キャッシュシステムやイベントリスナーなどのシナリオに適しています。オブジェクトの生存を保証することはできず、ごみ収集が遅れる可能性があることに注意する必要があります。
PHPで__invoke Magicメソッドを説明してください。Apr 12, 2025 am 12:07 AM\ _ \ _ Invokeメソッドを使用すると、オブジェクトを関数のように呼び出すことができます。 1。オブジェクトを呼び出すことができるように\ _ \ _呼び出しメソッドを定義します。 2。$ obj（...）構文を使用すると、PHPは\ _ \ _ Invokeメソッドを実行します。 3。ロギングや計算機、コードの柔軟性の向上、読みやすさなどのシナリオに適しています。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
R.E.P.O.説明されたエネルギー結晶と彼らが何をするか（黄色のクリスタル）
3週間前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最高のグラフィック設定
3週間前By尊渡假赌尊渡假赌尊渡假赌
アサシンのクリードシャドウズ：シーシェルリドルソリューション
2週間前ByDDD
R.E.P.O.誰も聞こえない場合はオーディオを修正する方法
3週間前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25：Myriseのすべてのロックを解除する方法
4週間前By尊渡假赌尊渡假赌尊渡假赌
ホットツール
AtomエディタMac版ダウンロード
最も人気のあるオープンソースエディター
ZendStudio 13.5.1 Mac
強力な PHP 統合開発環境
SublimeText3 中国語版
中国語版、とても使いやすい
WebStorm Mac版
便利なJavaScript開発ツール
VSCode Windows 64 ビットのダウンロード
Microsoft によって発売された無料で強力な IDE エディター
