MySQL数据库操作类(PHP实现，支持连贯操作)_MySQL
データベース
使用过ThinkPHP框架的同学可能会对于其中数据库模型操作特别有好感，ThinkPHP提供了数据库操作的简单的操作，对于连接数据库，数据库的增删改查等数据操作都非常的nice，同时支持连贯操作，对于那些不习惯写sql语句的同学真是大大的便利。(注：sql还是很重要的，不要因为用了框架就把原先的忘了)。
而在笔者使用php操作redis实现后台任务的过程中，也想要借助这种便利，但无奈redis操作单独的类，直接访问其中的controller文件的话，总是会提示M方法失败，导致此模型方法不能使用。万般无奈之下，只能自己来实现一下了。
借助PHP的mysqli相关函数，进行MySQL数据库操作类的实现。此程序中提供数据库的操作包括：数据库的连接，数据库的选择，数据库用户的选择，相应数据库中所有数据表名的查看；数据表的操作包括：相应的数据表中字段全部属性的查看，数据表的增删改查操作，数据表查询、插入的连贯操作等
<code class="hljs xml">_initialize();
if(!isset($host)||!isset($user)||!isset($passowrd)||!isset($database)){
return false;
}else{
$this->_host = $host;
$this->_user = $user;
$this->_password = $passowrd;
$this->_database = $database;
$this->_port = $port;
$_dbObj = new mysqli($host,$user,$passowrd,$database,$port);
if($_dbObj->connect_errno){
$this->error = $_dbObj->connect_error;
return false;
}else{
$this->_dbObj = $_dbObj;
return $this;
}
}
}
/**
* 错误信息函数
* 返回数据库操作过程中最后一次执行时的错误信息
* @access public
* @return mixed 数据库连接错误信息(正常返回'')
*/
public function error(){
return $this->error;
}
// 回调方法 初始化模型
protected function _initialize() {}
/**
* 设置数据对象的值
* @access public
* @param string $name 名称
* @param mixed $value 值
* @return void
*/
public function __set($name,$value) {
// 设置数据对象属性
$this->data[$name] = $value;
}
/**
* 获取数据对象的值
* @access public
* @param string $name 名称
* @return mixed
*/
public function __get($name) {
return isset($this->data[$name])?$this->data[$name]:null;
}
/**
* 检测数据对象的值
* @access public
* @param string $name 名称
* @return boolean
*/
public function __isset($name) {
return isset($this->data[$name]);
}
/**
* 销毁数据对象的值
* @access public
* @param string $name 名称
* @return void
*/
public function __unset($name) {
unset($this->data[$name]);
}
/**
* 利用__call方法实现一些特殊的方法(对于调用类中不存在方法的解决方案)
* @access public
* @param string $method 方法名称
* @param array $args 调用参数
* @return mixed
*/
public function __call($method,$args) {
/*if(in_array(strtolower($method),$this->methods,true)) {
// 连贯操作的实现
$this->options[strtolower($method)] = $args[0];
return $this;
}elseif(in_array(strtolower($method),array('count','sum','min','max','avg'),true)){
// 统计查询的实现
$field = isset($args[0])?$args[0]:'*';
return ;
}elseif(strtolower(substr($method,0,5))=='getby') {
// 根据某个字段获取记录
$field = parse_name(substr($method,5));
$where[$field] = $args[0];
return ;
}elseif(strtolower(substr($method,0,10))=='getfieldby') {
// 根据某个字段获取记录的某个值
$name = parse_name(substr($method,10));
$where[$name] =$args[0];
return ;
}elseif(isset($this->_scope[$method])){// 命名范围的单独调用支持
return ;
}else{
}*/
}
/*
* 选择数据库
* @access public
* @param string $database 选择的数据库名称
* @return mixed 数据库连接信息
* */
public function select_db($database){
$select_db = mysqli_select_db($this->_dbObj,$database);
if($select_db){
$this->_database = $database;
$_dbObj = new mysqli($this->_host,$this->_user,$this->_password,$database,$this->_port);
$this->_dbObj = $_dbObj;
return $this;
}else{
$this->error = mysqli_error($this->_dbObj);
return false;
}
}
/*
* 数据库用户更换
* @access public
* @param string $user 数据库用户名称
* @param string $password 数据库用户密码
* @return mixed 数据库连接信息
* */
public function change_user($user,$password){
$change_user = mysqli_change_user($this->_dbObj,$user,$password,$this->_database);
if($change_user){
$this->_user = $user;
$this->_password = $password;
$_dbObj = new mysqli($this->_host,$this->_user,$this->_password,$this->_database,$this->_port);
$this->_dbObj = $_dbObj;
return $this;
}else{
$this->error = mysqli_error($this->_dbObj);
return false;
}
}
/*
* 查询数据库中所有的表名
* @access public
* @return array 数据表的数量和表名
* */
public function tables(){
$sql = 'show tables';
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$num_rows = $search_res->num_rows;
$tables_msg = array(
'count'=>$num_rows,
'tables'=>array()
);
for($i=0;$i<$num_rows;$i++){
$row = $search_res->fetch_assoc();
$key = 'Tables_in_'.$this->_database;
array_push($tables_msg['tables'],$row[$key]);
}
mysqli_free_result($search_res);
return $tables_msg;
}else{
mysqli_free_result($search_res);
return false;
}
}
/*
* 获取指定表中所有信息
* @access public
* @param string $table 数据表名称
* @return array 数据表的详细信息
* */
public function select_table($table){
$sql = 'select * from '.$table;
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$this->_table = $table;
$table_msg = self::query_handle($search_res);
$this->_tableObj = $table_msg;
mysqli_free_result($search_res);
return $table_msg;
}else{
mysqli_free_result($search_res);
return false;
}
}
/*
* 获取指定表的字段详细信息
* @access public
* @param string $table 数据表名称
* @return array 数据表的字段详细信息
* */
public function select_table_fields($table){
$sql = 'show fields from '.$table;
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$this->_table = $table;
$fields_msg = self::query_handle($search_res);
mysqli_free_result($search_res);
return $fields_msg;
}else{
mysqli_free_result($search_res);
return false;
}
}
/*
* 获取数据表中指定字段信息（允许多字段同时查询）
* @access public
* @param mixed $field 指定字段（字符串传入使用，间隔）
* @return array 数据表中指定字段信息
* */
public function getField($field){
$fields = self::param_handle($field);
$count = count($fields);
for($i=0;$i<$count;$i++){
$index = $fields[$i];
$sql = 'select '.$index.' from '.$this->_table;
$res = mysqli_query($this->_dbObj,$sql);
$field_msg[$index] = self::query_handle($res);
}
return $field_msg;
}
/*
* mysqli_query函数结果处理函数
* @access protected
* @param object $obj mysqli_query函数结果
* @return array 数据表中指定字段信息
* */
protected function query_handle($obj){
$res = array();
for($i=0;$i<$obj->num_rows;$i++){
$row = $obj->fetch_assoc();
array_push($res,$row);
}
return $res;
}
/*
* 传入参数处理函数
* @access protected
* @param mixed $param 传入参数
* @return array 处理后数组数据
* */
public function param_handle($param){
if(is_string($param)&&!empty($param)){
$params = explode(',',$param);
}elseif(is_array($param)&&!empty($param)){
$params = $param;
}else{
return false;
}
return $params;
}
/*
* 查询表达式参数处理函数
* @access protected
* @param mixed $param 传入参数(where limit order)
* @return string 处理后字符串数据
* */
public function options_handle($param){
if(is_numeric($param)){
$option = $param;
}elseif(is_string($param)&&!empty($param)&&!is_numeric($param)){
$params = explode(',',$param);
$count = count($params);
$option = implode(' and ',$params);
}elseif(is_array($param)&&!empty($param)){
$params = $param;
$count = count($params);
$arr = array();
foreach($param as $key=>$value){
$tip = "$key=$value ";
array_push($arr,$tip);
}
$option = implode(' and ',$arr);
}else{
return false;
}
return $option;
}
/*
* 查询表达式$options处理函数
* @access protected
* @return string 处理后字符串数据
* */
protected function option(){
$options = $this->options;
$option = '';
if(isset($options['where'])){
$option .= 'where '.$options['where'].' ';
}
if(isset($options['order'])){
$option .= 'order by '.$options['order'].' '.$options['order_type'].' ';
}
if(isset($options['limit'])){
$option .= 'limit '.$options['limit'];
}
return $option;
}
/*
* 根据查询表达式查询数据(符合条件的所有记录)
* @access public
* @return array 满足查询表达式的特定数据
* */
public function find(){
$option = self::option();
$sql = 'select * from '.$this->_table.' '.$option;
$search_res = mysqli_query($this->_dbObj,$sql);
$msg = self::query_handle($search_res);
return $msg;
}
/*
* 查询表达式 where处理函数
* @access public
* @param mixed $where where查询条件
* @return object $this
* */
public function where($where){
$this->options['where'] = self::options_handle($where);
return $this;
}
/*
* 查询表达式 limit处理函数
* @access public
* @param mixed $limit limit查询条件(数字)
* @return object $this
* */
public function limit($limit){
$this->options['limit'] = self::options_handle($limit);
return $this;
}
/*
* 查询表达式 order处理函数
* @access public
* @param string $order order查询条件
* @param string $type order查询条件的顺序（默认降序）
* @return object $this
* */
public function order($order,$type='desc'){
$this->options['order'] = $order;
$this->options['order_type'] = $type;
return $this;
}
/*
* 数据处理函数(最多处理二维数据)
* @access public
* @param array $data 需要插入的数据
* @return object $this
* */
public function data(array $data){
$values = array();
$fields = array();
if(is_array($data)){
foreach($data as $key=>$value){
if(is_array($value)){ //二维数组
$tip = 1;
array_push($values,'('.implode(',',array_values($value)).')');
array_push($fields,'('.implode(',',array_keys($value)).')');
}else{ //一维数组
$tip = 0;
}
}
}else{
return false;
}
if(!$tip){
array_push($values,'('.implode(',',array_values($data)).')');
array_push($fields,'('.implode(',',array_keys($data)).')');
}
$this->data['fields'] = $fields[0];
$this->data['values'] = implode(',',$values);
return $this;
}
/*
* 数据新增函数
* @access public
* @return mixed 数据库新增信息
* */
public function add(){
$fields = $this->data['fields'];
$values = $this->data['values'];
$sql = 'INSERT INTO '.$this->_table.$fields.'VALUES'.$values;
$res = mysqli_query($this->_dbObj,$sql);
return $res;
}
/*
* 数据更新函数（一维数组）
* @access public
* @param array $data 需要更新的数据
* @return mixed 数据库新增信息
* */
function save(array $data){
$tip = array();
if(is_array($data)){
foreach($data as $key=>$value){
array_push($tip,"$key=$value");
}
}else{
return false;
}
$set_msg = implode(',',$tip);
$sql = 'UPDATE '.$this->_table.' SET '.$set_msg.' WHERE '.$this->options['where'];
$res = mysqli_query($this->_dbObj,$sql);
return $res;
}
/*
* 数据删除函数
* @access public
* @return mixed 数据库删除信息
* */
public function delete(){
$sql = 'DELETE FROM '.$this->_table.' WHERE '.$this->options['where'];
$res = mysqli_query($this->_dbObj,$sql);
return $res;
}
/*
* SQL语句查询
* */
public function query($sql){
$search_res = mysqli_query($this->_dbObj,$sql);
return $search_res;
}
/*
* mysql中查询语句
* */
protected function sql(){
/*
* 基本SQL语句
* 插入数据：INSERT INTO tb_name(id,name,score)VALUES(NULL,'张三',140),(NULL,'张四',178),(NULL,'张五',134);
* 更新语句：UPDATE tb_name SET score=189 WHERE id=2;
* 删除数据：DELETE FROM tb_name WHERE id=3;
* WHERE语句：SELECT * FROM tb_name WHERE id=3;
* HAVING 语句：SELECT * FROM tb_name GROUP BY score HAVING count(*)>2
* 相关条件控制符：=、>、<、<>、IN(1,2,3......)、BETWEEN a AND b、NOT AND 、OR Linke()用法中 % 为匹配任意、 _ 匹配一个字符（可以是汉字）IS NULL 空值检测
* MySQL的正则表达式：SELECT * FROM tb_name WHERE name REGEXP '^[A-D]' //找出以A-D 为开头的name
* */
}
/*
* 关闭连接
* */
public function close(){
$close = mysqli_close($this->_dbObj);
if($close){
return true;
}else{
return false;
}
}
function __destruct(){
mysqli_close($this->_dbObj);
}
}</code>ログイン後にコピー
操作示例：
首先实例化此类，其中需要输入host(数据库地址)、user(数据库用户)、password(数据库用户密码)、database(数据库名称)此四种信息，进行数据库的连接，然后即可调用select_table()方法，其中传入数据表名，从而设置对指定表的操作，从而即可利用连贯操作进行相应数据的增删改查。 其中参数基本均支持字符串和数组两种形式。
<code class="hljs bash">include '/classes/db.php';
$db = new \Database('localhost', 'root', '901230', 'weixin');
//$db = new \mysqli('localhost','root','901230','weixin');
//$db->select_db('visitor');
//dump($db->error());
//$db->change_user('helen','901230');
$table = 'zyd_fuweng_user';
//dump($db->select_table_fields($table));
//dump($db->error());
$db->select_table($table);
$param1 = '123';
$param2 = 'id>1,record>100';
$param3 = array(
/*array('count'=>1,'openid'=>'123','record'=>'100'),
array('count'=>2,'openid'=>'234','record'=>'200'),*/
array('count' => 4, 'openid' => '456', 'record' => '500')
);
$param4 = array('count' => 4, 'openid' => '456', 'record' => '500');
//dump($db->where('id=4')->save($param4));
dump($db->where('count=4')->delete());
die;
dump($db->data($param3)->add());
dump(array_keys($param3));
dump(array_values($param3));
dump(implode(',', array_values($param3)));
dump(implode(',', array_keys($param3)));
dump($db->where($param2)->order('id')->limit(2)->find());
dump($db->options_handle($param1));
dump($db->options_handle($param2));
dump($db->options_handle($param3));
$array = array('id', 'count');
$num = '123';
if (is_string($num)) {
echo 'true';
}
dump($db->getField($array));
dump($db->select_table_fields($table));
/*$array = array('a','b');
$array1 = array();
dump($db->getField('a,b'));
dump($db->getField($array));
dump($db->getField($array1));
dump($db->getField(''));*/
/*$str = '';
if(empty($str)){
echo 'true';
}*/
/*$model = M('zyd_fuweng_user');
$res = $model->getField('create_time,count');
dump($res);*/
die;
//
$table = 'zyd_fuweng_user';
//选择指定的数据库，并返回其中全部信息
$table_msg = $db->select_table($table);
//选择指定数据库，返回数据库的字段信息
$table_field_msg = $db->select_table_fields($table);
//条件搜索，传入条件均为数据
$where = array(
'id' => 1
);
$data = array(
'headimgurl' => 'helen.jpg'
);
dump($db->where($where)->field('field'));
dump($table);
/*$dbObj = new \mysqli('localhost','helen','901230','weixin','3306');
//$query = 'select * from zyd_fuweng_user';
$query = 'show fields from zyd_fuweng_user';
$tables = mysqli_query($dbObj,$query);
//dump($tables);
$count = $tables->num_rows;
$arr = array();
for($i=0;$i<$count;$i++){
$row = $tables->fetch_assoc();
//dump($row);
array_push($arr,$row);
}
mysqli_free_result($tables);
dump($arr);
die;
$query1 = 'select * from zyd_fuweng_user';
$table_msg = mysqli_query($dbObj,$query1);
//输出查询结果
$num = $table_msg->num_rows;
for($i=0;$i<$num;$i++){
$row = $table_msg->fetch_assoc();
dump($row);
}
dump($dbObj);
dump($tables);
dump($table_msg);
$res = mysqli_close($dbObj);
dump($res);*/
</code>ログイン後にコピー
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
アサシンのクリードシャドウズ：シーシェルリドルソリューション
3週間前
By DDD
Windows11 KB5054979の新しいものと更新の問題を修正する方法
2週間前
By DDD
Atomfallのクレーンコントロールキーカードを見つける場所
3週間前
By DDD
R.E.P.O.で節約説明した（そしてファイルを保存）
1 か月前
By 尊渡假赌尊渡假赌尊渡假赌
アサシンクリードシャドウ - 鍛冶屋を見つけて武器と鎧のカスタマイズを解除する方法
4週間前
By DDD
ホットツール
メモ帳++7.3.1
使いやすく無料のコードエディター
SublimeText3 中国語版
中国語版、とても使いやすい
ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境
ドリームウィーバー CS6
ビジュアル Web 開発ツール
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
ホットトピック
Gmailメールのログイン入り口はどこですか？
7569
15
7569
15
CakePHP チュートリアル
1386
52
1386
52
Steamのアカウント名の形式は何ですか
87
11
87
11
NYTの接続はヒントと回答です
28
108
28
108
Go 言語はデータベースの追加、削除、変更、クエリ操作をどのように実装しますか?
Mar 27, 2024 pm 09:39 PM
Go 言語は、効率的かつ簡潔で習得が容易なプログラミング言語であり、同時プログラミングやネットワーク プログラミングに優れているため、開発者に好まれています。実際の開発ではデータベースの操作が欠かせませんが、今回はGo言語を使ってデータベースの追加・削除・変更・クエリ操作を実装する方法を紹介します。 Go 言語では、データベースを操作するために通常、よく使用される SQL パッケージや gorm などのサードパーティ ライブラリを使用します。ここでは SQL パッケージを例として、データベースの追加、削除、変更、クエリ操作を実装する方法を紹介します。 MySQL データベースを使用していると仮定します。
iOS 18では、紛失または破損した写真を復元するための新しい「復元」アルバム機能が追加されます
Jul 18, 2024 am 05:48 AM
Apple の最新リリースの iOS18、iPadOS18、および macOS Sequoia システムでは、さまざまな理由で紛失または破損した写真やビデオをユーザーが簡単に回復できるように設計された重要な機能が写真アプリケーションに追加されました。この新機能では、写真アプリのツール セクションに「Recovered」というアルバムが導入され、ユーザーがデバイス上に写真ライブラリに含まれていない写真やビデオがある場合に自動的に表示されます。 「Recovered」アルバムの登場により、データベースの破損、カメラ アプリケーションが写真ライブラリに正しく保存されない、または写真ライブラリを管理するサードパーティ アプリケーションによって失われた写真やビデオに対する解決策が提供されます。ユーザーはいくつかの簡単な手順を実行するだけで済みます
Hibernate はポリモーフィック マッピングをどのように実装しますか?
Apr 17, 2024 pm 12:09 PM
Hibernate ポリモーフィック マッピングは、継承されたクラスをデータベースにマップでき、次のマッピング タイプを提供します。 join-subclass: 親クラスのすべての列を含む、サブクラス用の別個のテーブルを作成します。 table-per-class: サブクラス固有の列のみを含む、サブクラス用の別個のテーブルを作成します。 Union-subclass: join-subclass と似ていますが、親クラス テーブルがすべてのサブクラス列を結合します。
PHP で MySQLi を使用してデータベース接続を確立するための詳細なチュートリアル
Jun 04, 2024 pm 01:42 PM
MySQLi を使用して PHP でデータベース接続を確立する方法: MySQLi 拡張機能を含める (require_once) 接続関数を作成する (functionconnect_to_db) 接続関数を呼び出す ($conn=connect_to_db()) クエリを実行する ($result=$conn->query()) 閉じる接続 ( $conn->close())
PHP でデータベース接続エラーを処理する方法
Jun 05, 2024 pm 02:16 PM
PHP でデータベース接続エラーを処理するには、次の手順を使用できます。 mysqli_connect_errno() を使用してエラー コードを取得します。 mysqli_connect_error() を使用してエラー メッセージを取得します。これらのエラー メッセージをキャプチャしてログに記録することで、データベース接続の問題を簡単に特定して解決でき、アプリケーションをスムーズに実行できるようになります。
HTML がデータベースを読み取る方法の詳細な分析
Apr 09, 2024 pm 12:36 PM
HTML はデータベースを直接読み取ることはできませんが、JavaScript と AJAX を通じて実現できます。この手順には、データベース接続の確立、クエリの送信、応答の処理、ページの更新が含まれます。この記事では、JavaScript、AJAX、および PHP を使用して MySQL データベースからデータを読み取る実践的な例を示し、クエリ結果を HTML ページに動的に表示する方法を示します。この例では、XMLHttpRequest を使用してデータベース接続を確立し、クエリを送信して応答を処理することで、ページ要素にデータを埋め込み、データベースを読み取る HTML の機能を実現します。
PHP を使用してデータベース内の中国語の文字化けを処理するためのヒントと実践
Mar 27, 2024 pm 05:21 PM
PHP は Web サイト開発で広く使用されているバックエンド プログラミング言語であり、強力なデータベース操作機能を備えており、MySQL などのデータベースとの対話によく使用されます。ただし、中国語の文字エンコーディングは複雑であるため、データベース内で中国語の文字化けを処理するときに問題が発生することがよくあります。この記事では、文字化けの一般的な原因、解決策、具体的なコード例を含め、データベース内の中国語の文字化けを処理するための PHP のスキルと実践方法を紹介します。文字化けの一般的な原因は、データベースの文字セット設定が正しくないことです。データベースの作成時に、utf8 や u などの正しい文字セットを選択する必要があります。
Golangを使用してリモートデータベースに接続するにはどうすればよいですか?
Jun 01, 2024 pm 08:31 PM
Go 標準ライブラリのデータベース/SQL パッケージを通じて、MySQL、PostgreSQL、SQLite などのリモート データベースに接続できます。データベース接続情報を含む接続文字列を作成します。 sql.Open() 関数を使用してデータベース接続を開きます。 SQL クエリや挿入操作などのデータベース操作を実行します。 defer を使用してデータベース接続を閉じ、リソースを解放します。
