PHP7原生MySQL数据库操作实现代码

吾爱主题阅读：143 2021-10-19 13:13:00 评论：0

php7中mysql的连接与使用与PHP5中大不相同

PHP5中mysql_connect()等函数大多被PHP7中类的成员函数所代替。PHP5中连接mysql是过程性的，而PHP7中强调了类的使用与面向对象的方法

1 2 3 4 $user = new mysqli(); //Connect to mysql $user ->connect( "localhost" , "root" , "q721@Ms67" , "Student" );

mysql的连接被mysqli类所替代

1 2 3 4 //Search in mysql $query = 'SELECT * FROM users' ; //Use a variable to save result $result = $user ->query( $query );

查询语句也变成了类的成员函数

连接到 MySQL服务器

mysqli_connect(host, username, password [,dbname] [,port]);
- 参数：
host：MySQL服务器。可以包含端口号，默认值为“localhost:3306”
username：用户名。默认值是服务器进程所有者的用户名；
password：密码。
dbname：数据库名称。
port：MySQL服务器的端口号，默认为3306。
- 返回值：如果连接成功，则返回 mysqli 连接对象。如果失败，则返回 false。

实例代码一

1 2 3 4 5 6 7 8 9 <?php $mysqli = new mysqli( "localhost" , "root" , "password" , "testgame" ); if (! $mysqli ) { echo "database error" ; } else { echo "php env successful" ; } $mysqli ->close(); ?>

localhost 意思是本地主机，如果你是在自己电脑上的话，这项就不用改了
root是mysql的用户名，如果你是默认的没有修改，也不用管，直接copy
password 这事mysql的密码，如果你没有试着的话，直接写空的就行，""这样哦

代码二

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 <?php /* Connect to a MySQL server 连接数据库服务器 */ $link = mysqli_connect( 'localhost' , /* The host to connect to 连接MySQL地址 */ 'root' , /* The user to connect as 连接MySQL用户名 */ 'root' , /* The password to use 连接MySQL密码 */ 'lucax_database' ); /* The default database to query 连接数据库名称*/ if (! $link ) { printf( "Can't connect to MySQL Server. Errorcode: %s " , mysqli_connect_error()); exit ; } else echo '数据库连接上了！' ; /* Close the connection 关闭连接*/ mysqli_close( $link ); ?>

代码三

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 <?php $servername = "localhost" ; $username = "root" ; $password = "root" ; $dbname = "myDB" ; // 创建连接 # Tip: 如果你使用其他端口（默认为3306），为数据库参数添加空字符串，如: new mysqli( "localhost" , "username" , "password" , "" , port) $conn = new mysqli( $servername , $username , $password , $dbname ); // 检测连接 if ( $conn ->connect_error) { die ( "连接失败: " . $conn ->connect_error); } echo "连接成功" ; $conn ->close(); ?>

选择当前数据库

mysqli_select_db(mysqliLink, database)
- 描述：一个数据库服务器可能包含很多的数据库，通常需要针对某个具体的数据库进行编程
- 返回值：如果成功返回TRUE，失败则返回FALSE

设置客户端字符集

mysqli_set_charset(mysqliLink, charset)
- 描述：设置默认字符编码
- 返回：成功时返回 TRUE，或者在失败时返回 FALSE。

发送一条 MySQL 查询

mysqli_query(mysqliLink , queryStr)
- 参数：
query是查询字符串；
link是创建的活动的数据库连接；
- 说明：mysqli_query() 仅对 SELECT，SHOW 或 DESCRIBE 语句返回一个mysqli_result结果集对象，如果查询执行不正确则返回 FALSE。对于其它类型的 SQL 语句，mysqli_query()在执行成功时返回 TRUE，出错时返回 FALSE。非 FALSE 的返回值意味着查询是合法的并能够被服务器执行。
- 注意：查询字符串不应以分号结束，和命令行模式下有区别。

从结果集中取得一行作为关联数组，或数字数组，或二者兼有

mysqli_fetch_array ( mysqliResult [, resultType] )
- 参数：resultType是一个常量，取值：MYSQLI_BOTH(两者兼有，默认)、MYSQLI_ASSOC(关联索引)、MYSQLI_NUM(数字索引)
- 返回：返回根据从结果集取得的行生成的数组，如果没有更多行则返回 FALSE。
- 注意：本函数返回的字段名区分大小写。

从结果集中取得所有行作为关联数组、枚举数组、或二者兼有

mysqli_fetch_all(mysqliResult [, resultType ])
- 参数：$result_type是一个常量，取值：MYSQLI_BOTH(两者兼有，默认)、MYSQLI_ASSOC(关联索引)、MYSQLI_NUM(数字索引)
- 返回：返回根据从结果集取得的行生成的数组，如果没有更多行则返回 FALSE。
- 注意：本函数返回的字段名区分大小写。

取得结果集中行的数目

mysqli_num_rows(mysqliResult)
- 注意：此命令仅对 SELECT 语句有效。

从结果集中取得一行作为关联数组

array mysqli_fetch_assoc(mysqliResult)
- 返回值：从结果集取得的行生成的关联数组，如果没有更多行则返回 FALSE；
- 注意：此函数返回的字段名大小写敏感。

取得前一次 MySQL 操作所影响的记录行数

mysqli_affected_rows ( mysqliLink )
- 说明：取得最近一次与 $link 关联的 SELECT、INSERT、UPDATE 或 DELETE 查询所影响的记录行数。
- 注意：如果最近一次查询失败，函数返回-1。当使用UPDATE查询，MySQL不会将原值和新值一样的值更新，返回值不一定就是查询条件所符合的记录，只有修改过的记录数才会被返回。

释放与结果集相关联的内存

mysqli_free_result(mysqliResult)
- 参数：mysqliResult为结果集对象。

返回上一个 MySQL 连接产生的文本错误信息

mysqli_connect_error()
- 参数：没有参数

php7创建数据库：

方法一:

1 2 3 4 5 6 $sql = "CREATE DATABASE myDB3" ; if (mysqli_query( $conn , $sql )) { echo "数据库创建成功" ; } else { echo "Error creating database: " . mysqli_error( $conn ); }

方法二:

1 2 3 4 5 6 7 8 9 10 11 12 // 检测连接 if ( $conn ->connect_error) { 　　 die ( "连接失败: " . $conn ->connect_error); } echo "连接成功" ; $sql = "CREATE DATABASE myDB2" ; if ( $conn ->query( $sql ) === TRUE) { 　　 echo "数据库创建成功" ; } else { 　　 echo "Error creating database: " . $conn ->error; }

创建表的方法：

方法一:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 // 使用 sql 创建数据表 $sql = "CREATE TABLE MyGuests ( id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY, firstname VARCHAR(30) NOT NULL, lastname VARCHAR(30) NOT NULL, email VARCHAR(50), reg_date TIMESTAMP )"; if (mysqli_query( $conn , $sql )) { echo "数据表 MyGuests 创建成功" ; } else { echo "创建数据表错误: " . mysqli_error( $conn ); }

方法二:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 // 使用 sql 创建数据表 $sql = "CREATE TABLE MyGuests2 ( id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY, firstname VARCHAR(30) NOT NULL, lastname VARCHAR(30) NOT NULL, email VARCHAR(50), reg_date TIMESTAMP )"; if ( $conn ->query( $sql ) === TRUE) { echo "Table MyGuests created successfully" ; } else { echo "创建数据表错误: " . $conn ->error; }

插入数据的方法:

方法一:

1 2 3 4 5 6 7 8 $sql = "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( 'John' , 'Doe' , 'john@example.com' )"; if (mysqli_query( $conn , $sql )) { echo "新记录插入成功" ; } else { echo "Error: " . $sql . " " . mysqli_error( $conn ); }

方法二:

1 2 3 4 5 6 7 8 $sql = "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( 'John' , 'Doe' , 'john@example.com' )"; if ( $conn ->query( $sql ) === TRUE) { echo "新记录插入成功" ; } else { echo "Error: " . $sql . " " . $conn ->error; }

插入多条数据的方法:

方法一:

1 2 3 4 5 6 7 8 9 10 11 12 $sql = "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( 'John' , 'Doe' , 'john@example.com' );"; $sql .= "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( 'Mary' , 'Moe' , 'mary@example.com' );"; $sql .= "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( 'Julie' , 'Dooley' , 'julie@example.com' )"; if (mysqli_multi_query( $conn , $sql )) { echo "新记录插入成功" ; } else { echo "Error: " . $sql . " " . mysqli_error( $conn ); }

方法二：

1 2 3 4 5 6 7 8 9 10 11 12 $sql = "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( '22' , 'Doe' , 'john@example.com' );"; $sql .= "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( '22' , 'Moe' , 'mary@example.com' );"; $sql .= "INSERT INTO MyGuests (firstname, lastname, email) VALUES ( '22' , 'Dooley' , 'julie@example.com' )"; if ( $conn ->multi_query( $sql ) === TRUE) { echo "新记录插入成功" ; } else { echo "Error: " . $sql . " " . $conn ->error; }

查询数据库的方法：

方法一:

1 2 3 4 5 6 7 8 9 10 11 $sql = "SELECT id, firstname, lastname FROM MyGuests" ; $result = mysqli_query( $conn , $sql ); if (mysqli_num_rows( $result ) > 0) { // 输出数据 while ( $row = mysqli_fetch_assoc( $result )) { echo "id: " . $row [ "id" ]. " - Name: " . $row [ "firstname" ]. " " . $row [ "lastname" ]. " " ; } } else { echo "0 结果" ; }

方法二：

1 2 3 4 5 6 7 8 9 10 11 $sql = "SELECT id, firstname, lastname FROM MyGuests" ; $result = $conn ->query( $sql ); if ( $result ->num_rows > 0) { // 输出数据 while ( $row = $result ->fetch_assoc()) { echo "id: " . $row [ "id" ]. " - Name: " . $row [ "firstname" ]. " " . $row [ "lastname" ]. " " ; } } else { echo "0 结果" ; }

看到这里服务器之家小编再为大家分享一个整理好的类库

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 <?php /** * 数据库操作类 */ !defined( 'ROOTNAME' ) && exit ( 'FORBIDDEN' ); class db_mysql{ var $query_num = 0; var $link ; function __construct( $dbhost , $dbuser , $dbpw , $dbname ) { $this ->connect( $dbhost , $dbuser , $dbpw , $dbname ); } function connect( $dbhost , $dbuser , $dbpw , $dbname ) { // global $dbcharset; if (! $this ->link = @mysqli_connect( $dbhost , $dbuser , $dbpw , $dbname )) { $this ->halt( "Can not connect to MySQL server" ); } if ( $this ->server_info() > '5.0' ){ mysqli_query( $this ->link, "SET sql_mode=''" ); } /* if($dbname) { if (!@mysqli_select_db($dbname, $this->link)){ $this->halt('Cannot use database '.$dbname); } }*/ } function select_db( $dbname ) { $this ->dbname = $dbname ; if (!@mysqli_select_db( $dbname , $this ->link)){ $this ->halt( 'Cannot use database ' . $dbname ); } } function server_info() { return mysqli_get_server_info( $this ->link); } function version() { return mysqli_get_server_info( $this ->link); } function insert( $tableName , $column = array ()) { $columnName = "" ; $columnValue = "" ; foreach ( $column as $key => $value ) { $columnName .= $key . "," ; $columnValue .= "'" . $value . "'," ; } $columnName = substr ( $columnName , 0, strlen ( $columnName ) - 1); $columnValue = substr ( $columnValue , 0, strlen ( $columnValue ) - 1); $sql = "INSERT INTO $tableName($columnName) VALUES($columnValue)" ; $this ->query( $sql ); } function update( $tableName , $column = array (), $where = "" ) { $updateValue = "" ; foreach ( $column as $key => $value ) { $updateValue .= $key . "='" . $value . "'," ; } $updateValue = substr ( $updateValue , 0, strlen ( $updateValue ) - 1); $sql = "UPDATE $tableName SET $updateValue" ; $sql .= $where ? " WHERE $where" : null; $this ->query( $sql ); } function delete ( $tableName , $where = "" ){ $sql = "DELETE FROM $tableName" ; $sql .= $where ? " WHERE $where" : null; $this ->query( $sql ); } function select( $tableName , $columnName = "*" , $where = "" ) { $sql = "SELECT " . $columnName . " FROM " . $tableName ; $sql .= $where ? " WHERE " . $where : null; $this ->query( $sql ); } function get_all( $sql , $result_type = MYSQLI_ASSOC) { $query = $this ->query( $sql ); $i = 0; $rt = array (); while ( $row =& mysqli_fetch_array( $query , $result_type )) { $rt [ $i ]= $row ; $i ++; } //$this->write_log("获取全部记录 ".$sql); return $rt ; } function fetchRow( $query ){ return mysqli_fetch_assoc( $query ); } function query( $sql ) { //$this->write_log("查询 ".$sql); mysqli_query( $this ->link, "set names utf8" ); $query = mysqli_query( $this ->link, $sql ); //if(!$query) $this->halt('Query Error: ' . $sql); return $query ; } //获取第一个字段值 function getOne( $sql , $limited = false){ if ( $limited == true){ $sql = trim( $sql . ' LIMIT 1' ); } $res = $this ->query( $sql ); if ( $res !== false){ $row = mysqli_fetch_row( $res ); if ( $row !== false){ return $row [0]; } else { return '' ; } } else { return false; } } function fetch_array( $query , $result_type = MYSQLI_ASSOC) { return mysqli_fetch_array( $query , $result_type ); } //输出记录 function fetch_first( $sql ) { $res = $this ->query( $sql ); return $this ->fetch_array( $res ,MYSQLI_ASSOC); } // 取得一条数据记录 function get_one( $sql , $result_type = MYSQLI_ASSOC){ $result = $this ->query( $sql ); $record = $this ->fetch_array( $result , $result_type ); return $record ; } function getRow( $sql , $limited = false){ if ( $limited == true){ $sql = trim( $sql . 'LIMIT 1' ); } $res = $this ->query( $sql ); if ( $res !== false){ return mysqli_fetch_assoc( $res ); } else { return false; } } //取影响条数 function affected_rows() { return mysqli_affected_rows( $this ->link); } //从结果集中取得一行作为枚举数组 function fetch_row( $query ) { return mysqli_fetch_row( $query ); } // 结果条数 function num_rows( $query ) { return mysqli_num_rows( $query ); } // 取字段总数 function num_fields( $query ) { return mysqli_num_fields( $query ); } // 返回查询结果 function result( $query , $row ) { $query = mysqli_result( $query , $row ); return $query ; } //释放结果集 function free_result( $query ) { return mysqli_free_result( $query ); } //返回自增ID function insert_id() { return ( $id = mysqli_insert_id( $this ->link)) >= 0 ? $id : $this ->result( $this ->query( "SELECT last_insert_id()" ), 0); } function close() { return mysqli_close( $this ->link); } function error() { return (( $this ->link) ? mysqli_error( $this ->link) : '' ); } //返回错误信息 function errno() { return intval (( $this ->link) ? mysqli_errno( $this ->link) : '' ); } function halt( $msg = '' ) { global $charset ; $msg = "<html>\n<head>\n" ; $msg .= "<meta content=\"text/html; charset=$charset\" http-equiv=\"Content-Type\">\n" ; $msg .= "<style type=\"text/css\">\n" ; $msg .= "body,p,pre {\n" ; $msg .= "font:12px Verdana;\n" ; $msg .= "}\n" ; $msg .= "</style>\n" ; $msg .= "</head>\n" ; $msg .= "<body bgcolor=\"#FFFFFF\" text=\"#000000\" link=\"#006699\" vlink=\"#5493B4\">\n" ; $msg .= "error: " .htmlspecialchars( $this ->error()). "\n " ; $msg .= "error number: " . $this ->errno(). "\n " ; $msg .= "Date: " . date ( "Y-m-d @ H:i" ). "\n " ; $msg .= "Script File: http://" . $_SERVER [ 'HTTP_HOST' ]. getenv ( "REQUEST_URI" ). "\n " ; $msg .= "</body>\n</html>" ; echo $msg ; exit ; } } ?>

以上就是PHP7原生MySQL数据库操作实现代码的详细内容，更多关于php7 数据库操作方法的资料请关注服务器之家其它相关文章！

可以去百度分享获取分享代码输入这里。

声明

1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，请转载时务必注明文章作者和来源，不尊重原创的行为我们将追究责任；3.作者投稿可能会经我们编辑修改或补充。