PHP implements mysql (MySQL and MySQLi mode) operation class
This article mainly introduces the mysql operation class implemented by PHP, and analyzes the common method encapsulation and usage skills of MySQL and MySQLi to connect and operate MySQL database in the form of examples. Friends in need can refer to it
The example of this article describes the mysql operation class implemented by PHP. Share it with everyone for your reference, the details are as follows:
First is the mysql method
<?php class ConnectionMySQL{ //主机 private $host="localhost"; //数据库的username private $name="root"; //数据库的password private $pass=""; //数据库名称 private $table="phptest"; //编码形式 private $ut="utf-8"; //构造函数 function __construct(){ $this->ut=$ut; $this->connect(); } //数据库的链接 function connect(){ $link=mysql_connect($this->host,$this->name,$this->pass) or die ($this->error()); mysql_select_db($this->table,$link) or die("没该数据库:".$this->table); mysql_query("SET NAMES '$this->ut'"); } function query($sql, $type = '') { if(!($query = mysql_query($sql))) $this->show('Say:', $sql); return $query; } function show($message = '', $sql = '') { if(!$sql) echo $message; else echo $message.'<br>'.$sql; } function affected_rows() { return mysql_affected_rows(); } function result($query, $row) { return mysql_result($query, $row); } function num_rows($query) { return @mysql_num_rows($query); } function num_fields($query) { return mysql_num_fields($query); } function free_result($query) { return mysql_free_result($query); } function insert_id() { return mysql_insert_id(); } function fetch_row($query) { return mysql_fetch_row($query); } function version() { return mysql_get_server_info(); } function close() { return mysql_close(); } //向$table表中插入值 function fn_insert($table,$name,$value){ $this->query("insert into $table ($name) value ($value)"); } //根据$id值删除表$table中的一条记录 function fn_delete($table,$id,$value){ $this->query("delete from $table where $id=$value"); echo "id为". $id." 的记录被成功删除!"; } } $db = new ConnectionMySQL(); $db->fn_insert('test','id,name,sex',"'','hongtenzone','M'"); $db->fn_delete('test', 'id', 1); ?>
mysqli way:
<?php class Mysql{ private $LocalHost = 'localhost'; private $LoaclUser = ''; private $LocalPass = ''; private $LocalBase = ''; private $LocalCode = 'UTF8'; private $PreFix; private $Conn; private $Start = 0; private $Error = false; //数据库连接状态, false表示未连接或连接不正常 public $Err = true; //Sql执行结果 private $Table; private $Field = '*'; private $Where = ''; private $Order = ''; private $PageSize = 0; //分页显示->每页多少条,0为不分页显示 private $PageCount = 1; //分页显示->总共有多少条 private $PageNum = 1; //分页显示->总共有多少页 private $PageNo = 1; //分页显示->当前第几页 private $PageKey = 'page'; //分页url参数键 private $PageStart = 0; //分页显示->当前从第几条开始返回 private $Select; private $Rest; private $Result = false;//结果集 public $FormArray = array(); public $Instr_ID = 0; private $j = 0; public function Parameter($Loca, $Root, $Pass, $Base, $Code, $PreFix = ''){ $this->LoaclUser = $Root; $this->LocalBase = $Base; $this->LocalCode = $Code; $this->LocalHost = $Loca; $this->LocalPass = $Pass; $this->PreFix = $PreFix; return $this; } private function Connection( $Sql ){ !function_exists(mysqli_connect) ? die('查询失败,无法加载mysqli扩展') : null; $this->Conn = @new mysqli( $this->LocalHost, $this->LoaclUser, $this->LocalPass, $this->LocalBase); $this->Error = mysqli_connect_errno() == 0 ? true : false; !$this->Error ? die('数据库连接错误,请检查数据库连接参数') : null; $this->Conn->query('SET NAMES ' . $this->LocalCode); $this->Rest = $this->Conn->query($Sql); $this->Err = mysqli_error($this->Conn); $this->Instr_ID = mysqli_insert_id($this->Conn); $this->Rest->free_result; $this->Conn->close; $this -> FormArray = ''; return $this; } public function null(){ $this->PageSize = 0; //$this->PageCount = 1; $this->PageStart = 1; $this->Field = ' * '; $this->Select = ''; unset($this->Table, $this->Where,$this->Order, $this->Result); } public function Table( $TableName ) {//数据表 $this -> null(); $this->Table = '`' . $this->PreFix . $TableName . '`'; return $this; } public function Field( $Array = '*' ) {//数据字段 !empty( $this->Field ) ? $this->Field = '' : null; $Array = explode(',', $Array); foreach ( $Array as $field ) { $this->Field .= !$this->Start ? '`' . $field . '`' : ', `' . $field . '`'; $this->Start++; } $this->Start = 0; return $this; } public function Where( $Where ) {//条件 $this->Where = ' where ' .$Where; return $this; } public function Order( $Order ) {//排序 $this->Order = ' order by ' . $Order; return $this; } public function pk( $key ) {//分页url参数键 $this->PageKey = $key; return $this; } public function Page( $PageSize ) {//分页 $this->PageSize = $PageSize; $this->PageNo = $this->get( $this->PageKey ); $this->PageNo = empty( $this->PageNo ) || !isset( $this->PageNo ) || !is_numeric( $this->PageNo ) || $this->PageNo < 1 ? 1 : $this->PageNo; return $this; } public function post( $Key, $Filter = true ){ return $Filter ? strip_tags($_POST[$Key]) : $_POST[$Key]; } public function get( $Key, $Filter = true ){ return $Filter ? strip_tags($_GET[$Key]) : $_GET[$Key]; } public function Sel(){ $this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order; $this->Connection( $this->Select ); if ( $this->Rest->num_rows ) { while ( $Rs = $this->Rest->fetch_assoc() ) { $this->Result[] = $Rs; } } $DataBase = $this->Result; return empty($DataBase) ? false : $DataBase; } public function querys( $Sql = '', $Type = 'not', $biao = false ) { $this->Select = $Sql; $this->Connection( $this->Select ); if ( $this->Rest->num_rows ) { if ( !$biao ) { while ( $Rs = $this->Rest->fetch_array() ) { $this->Result[] = !preg_match('/^\d+$/i', $Type) ? $Rs : $Rs[ $Type ]; } } else { while ( $Rs = $this->Rest->fetch_assoc() ) { $this->Result[] = $Rs; } } } $DataBase = $this->Result; return empty($DataBase) ? false : $DataBase; } public function executes( $Sql = '' ){ $this->Connection( $Sql ); return $this->Rest; } public function exists( $T = '', $F = '', $W = ''){ if ( empty( $F ) ) { return 0; } $cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W; $this->Connection( $cmd ); unset( $T, $F, $W, $cmd ); $Rel = $this->Rest->fetch_array(); return round( $Rel['baiyinum'], 2 ); } public function ExistsTo( $Bili = 10000, $T = '', $F = '', $W = ''){ if ( empty( $F ) ) { return 0; } $cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W; $this->Connection( $cmd ); unset( $T, $F, $W, $cmd ); $Rel = $this->Rest->fetch_array(); return round( $Rel['baiyinum'] * $Bili ); } public function Select( $Type = true, $ListNum = 1 ){ //返回记录(数组形式, 返回条数) $this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order; if ( is_numeric( $ListNum ) ) { if ( $this->PageSize > 0 ) { $this->Connection( $this->Select );//执行查询 $this->PageCount = $this->Rest->num_rows;//取得记录总数 $this->PageNum = ceil($this->PageCount / $this->PageSize); //总共有多少页 $this->PageNo = $this->PageNo > $this->PageNum ? $this->PageNum : $this->PageNo; $this->PageStart = ( $this->PageNo - 1 ) * $this->PageSize; //当前从第几条开始返回 $this->Select .= ' limit ' . $this->PageStart . ', ' .$this->PageSize; //重新构造sql语句 } else { $this->Select .= ' limit ' . $ListNum; //重新构造sql语句 } } else { $this->Select .= ' limit 1'; //重新构造sql语句 } //echo $this->Select; $this->Connection( $this->Select );//再次执行查询 if ( $this->Rest->num_rows ) {//如果记录存在 if ( $Type ) { while ( $Rs = $this->Rest->fetch_array() ) { $this->Result[] = $Rs; } }else{ while ( $Rs = $this->Rest->fetch_assoc() ) { $this->Result[] = $Rs; } } } if ( ( $ListNum == 1 or !is_numeric( $ListNum ) ) && !$this->PageSize) { $this->Result = $this->Result[0]; } $DataBase = $this->Result; return empty($DataBase) ? false : $DataBase; } public function Num() { //返回记录总数 $this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order; $this->Connection( $this->Select );//执行查询 return $this->Rest->num_rows;//取得记录总数 } public function PageNav($NumNav = false ) { //分页 $Action = $this -> get('action'); !empty( $Action ) or $Action = 'index'; $Module = $this -> get('module'); !empty( $Module ) or $Module = 'index'; $NavUrl = '/' . $Module . '/' . $Action . '/' . $this -> PageKey .'/'; $NaIndex = '/' . $Module . '/' . $Action; $PageHtml = "\n<p class=\"pagenav\">"; $PageHtml .= '<span>' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页</span> '; $this->PageNo <= 1 or $PageHtml .= "<a href=\"" . $NaIndex . "\">首页</a>\n<a href=\"" . $NavUrl . ($this->PageNo - 1) . "\">上一页</a>\n"; if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); } $this->PageNo >= $this->PageNum or $PageHtml .= "<a href=\"" . $NavUrl. ($this->PageNo + 1) . "\">下一页</a>\n<a href=\"" . $NavUrl . $this->PageNum . "\">尾页</a>\n"; $PageHtml .= "</p>\n"; return $PageHtml; } private function NumPage( $Can = '' ) { //数字分页 $NumHtml = ''; $First = 1; $Last = $this->PageNum; if ( $this->PageNum > 5 ) { if ( $this->PageNo < $this->PageNum ) { $First = $this->PageNo - 2; $Last = $this->PageNo + 2; }else{ $First = $this->PageNo - 4; $Last = $this->PageNum; } } if ( $First < 1 ) { $First = 1; $Last = $First + 4;} if ( $Last > $this->PageNum ) { $First = $this->PageNum - 4; $Last = $this->PageNum;} for( $i = $First; $i <= $Last; $i++) { $NumHtml .= $this->PageNo != $i ? "\n\t" . '<a href="' . $Can . $i . '" rel="external nofollow" >' . $i . '</a>' . "\n\t" : "\n\t" .'<a class="hover" disabled="disabled">' . $i . '</a>' . "\n\t"; } unset($Can, $First, $i, $Last); return $NumHtml; } public function UserPage($NumNav = false, $PageName = 'index', $Mulu = 'user' ) { //会员中心分页 $NavUrl = '/' . $Mulu . '/' . $PageName . '/' . $this->PageKey . '/'; $PageHtml = "\n<p class=\"pagenav\">"; $PageHtml .= '<span>' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页</span> '; $this->PageNo <= 1 or $PageHtml .= "<a href=\"" . $NavUrl . "1\">首页</a>\n<a href=\"" . $NavUrl . ($this->PageNo - 1) . "\">上一页</a>\n"; if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); } $this->PageNo >= $this->PageNum or $PageHtml .= "<a href=\"" . $NavUrl. ($this->PageNo + 1) . "\">下一页</a>\n<a href=\"" . $NavUrl . $this->PageNum . "\">尾页</a>\n"; $PageHtml .= "</p><p class=\"clear\"></p>\n"; return $PageHtml; } //表单处理开始 //判断表单时候提交 public function FormIs( $Keys = 'mm' ) { return $_POST[ $Keys ] == 1 ? true : false; } //post方式获取数据 public function _post( $Keys = '', $TiHuan = '') { $Values = strip_tags( $_POST[ $Keys ] ); $this->FormArray[$Keys] = empty( $Values ) ? $TiHuan : $Values; return empty( $Values ) ? $TiHuan : $Values; } //get方法获取数据 public function _get( $Keys = '', $TiHuan = '') { $Values = strip_tags( $_GET[ $Keys ] ); return empty( $Values ) ? $TiHuan : $Values; } //判断是否为数字并且不小于0 public function IsNum( $Num = 0, $Mesg = '参数必须为数字' ) { if ( is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ) { return $Num; }else{ die( $Mesg ); } } //判断是否为数字并且不小于0返回True/False public function NumBer( $Num = 0) { return is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ? true : false; } //检测相关数据似乎存在 public function IsData($Types = true, $memg = '数据已经存在' ){ $this->Connection('select ' . $this->Field . ' from ' . $this->Table . $this->Where); if ( $Types ){ $this->Rest->num_rows > 0 ? die( $memg ) : null; } else { return $this->Rest->num_rows; } } //写入数据库记录 public function into( $Mesg = '' ){ !is_array( $this->FormArray ) ? die( $Mesg ) : null; $Sql = 'insert into ' . $this->Table . ' (`'; $I = 0; foreach ( $this->FormArray as $Key => $Val ){ $Duan .= !$I ? $Key . '`' : ', `' . $Key . '`'; if ( is_numeric( $Val ) ){ $Vals .= !$I ? $Val : ', ' . $Val; }else{ $Vals .= !$I ? '\'' . $Val . '\'' : ', \'' . $Val . '\''; } $I++; } $Sql .= $Duan . ') values (' . $Vals . ')'; //@file_put_contents('1.sql', $Sql, FILE_APPEND); $this->Connection( $Sql ); return !empty( $this->Err ) ? false : true; } //数组形式写入数据 public function MsgBox( $Table = '', $Filed = array() ) { $this -> Table($Table); foreach( $Filed as $Key => $Val ) { $this -> FormArray[ $Key ] = $Val; } return $this -> Into('未取得数据'); } //修改数据库记录 public function Edit( $Array = array() ) { if ( empty( $Array ) ) { $Array = $this -> FormArray; } if ( !is_array( $Array ) || empty( $Array ) ) { return false; } else { $Sql = 'update ' . $this -> Table . ' set '; $I = 0; $Sub = ''; $Huan = array('-' => '[jian]', '+' => '[jia]', '*' => '[cheng]', '/' => '[chu]'); $Zhan = array('[jian]' => '-', '[jia]' => '+', '[cheng]' => '*', '[chu]' => '/'); foreach ( $Array as $Files => $Val ) { $Val = !is_numeric( $Val ) && !preg_match('/\`\w+\`\s*(\+|\-|\*|\/)/i', $Val) ? '\'' . $Val . '\'' : $Val; foreach ( $Huan as $key => $val ){ $Val = str_replace($key, $val, $Val); } $duan = !$I ? '`' . $Files . '` = ' : ', `' . $Files . '` = '; $Sub .= $duan . $Val; $I++; } $Sql .= $Sub . $this -> Where; foreach ( $Zhan as $Fan => $Hui ) { $Sql = str_replace($Fan, $Hui, $Sql); } //echo $Sql; die; $this -> Connection( $Sql ); unset( $Array, $duan, $Fan, $Files, $Huan, $Hui, $I, $key, $Sql, $Sub, $Val, $Zhan, $val ); return !empty( $this -> Err ) ? false : true; } } //删除数据库记录 public function del(){ $Sql = 'delete from ' . $this->Table . $this->Where; $this->Connection( $Sql ); unset($Sql); return !empty( $this->Err ) ? false : true; } //表单处理结束 //页面跳转 public function Msg( $Text = '操作成功' ) { echo '<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />'; echo '<script type="text/javascript"> <!-- alert("' . $Text . '"); document.location="' . $_SERVER['HTTP_REFERER'] . '"; //--> </script>'; exit; } #取得系统当前时间 public function Times(){ return str_replace('-', '[jian]', date('Y-m-d H:i:s')); } #取得用户IP地址 public function GetIP(){ if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown")) $ip = getenv("HTTP_CLIENT_IP"); else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) $ip = getenv("HTTP_X_FORWARDED_FOR"); else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown")) $ip = getenv("REMOTE_ADDR"); else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) $ip = $_SERVER['REMOTE_ADDR']; else $ip = "unknown"; return($ip); } //最后关闭数据库连接 public function Close(){ !is_object( $this -> Conn ) or mysqli_close( $this -> Conn ); } }
The above is the detailed content of PHP implements mysql (MySQL and MySQLi mode) operation class. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Undress AI Tool
Undress images for free

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics

MySQL is an open source relational database management system, mainly used to store and retrieve data quickly and reliably. Its working principle includes client requests, query resolution, execution of queries and return results. Examples of usage include creating tables, inserting and querying data, and advanced features such as JOIN operations. Common errors involve SQL syntax, data types, and permissions, and optimization suggestions include the use of indexes, optimized queries, and partitioning of tables.

MySQL's position in databases and programming is very important. It is an open source relational database management system that is widely used in various application scenarios. 1) MySQL provides efficient data storage, organization and retrieval functions, supporting Web, mobile and enterprise-level systems. 2) It uses a client-server architecture, supports multiple storage engines and index optimization. 3) Basic usages include creating tables and inserting data, and advanced usages involve multi-table JOINs and complex queries. 4) Frequently asked questions such as SQL syntax errors and performance issues can be debugged through the EXPLAIN command and slow query log. 5) Performance optimization methods include rational use of indexes, optimized query and use of caches. Best practices include using transactions and PreparedStatemen

MySQL is chosen for its performance, reliability, ease of use, and community support. 1.MySQL provides efficient data storage and retrieval functions, supporting multiple data types and advanced query operations. 2. Adopt client-server architecture and multiple storage engines to support transaction and query optimization. 3. Easy to use, supports a variety of operating systems and programming languages. 4. Have strong community support and provide rich resources and solutions.

Apache connects to a database requires the following steps: Install the database driver. Configure the web.xml file to create a connection pool. Create a JDBC data source and specify the connection settings. Use the JDBC API to access the database from Java code, including getting connections, creating statements, binding parameters, executing queries or updates, and processing results.

The process of starting MySQL in Docker consists of the following steps: Pull the MySQL image to create and start the container, set the root user password, and map the port verification connection Create the database and the user grants all permissions to the database

The main role of MySQL in web applications is to store and manage data. 1.MySQL efficiently processes user information, product catalogs, transaction records and other data. 2. Through SQL query, developers can extract information from the database to generate dynamic content. 3.MySQL works based on the client-server model to ensure acceptable query speed.

Laravel is a PHP framework for easy building of web applications. It provides a range of powerful features including: Installation: Install the Laravel CLI globally with Composer and create applications in the project directory. Routing: Define the relationship between the URL and the handler in routes/web.php. View: Create a view in resources/views to render the application's interface. Database Integration: Provides out-of-the-box integration with databases such as MySQL and uses migration to create and modify tables. Model and Controller: The model represents the database entity and the controller processes HTTP requests.

The key to installing MySQL elegantly is to add the official MySQL repository. The specific steps are as follows: Download the MySQL official GPG key to prevent phishing attacks. Add MySQL repository file: rpm -Uvh https://dev.mysql.com/get/mysql80-community-release-el7-3.noarch.rpm Update yum repository cache: yum update installation MySQL: yum install mysql-server startup MySQL service: systemctl start mysqld set up booting
