您的位置：首页 > 编程技术 > php  >  简单实用MySQL数据库PHP操作类

简单实用MySQL数据库PHP操作类

 更新时间：2016年11月25日 16:34  点击：2207
下面是一个站长写的一个非常简单实用的数据库操作类了，这里面主要功能是数据库连接，查询数据,删除数据，更新数据等等，这个类的特点时不限制mysql而是直接执行由外部给出的sql语句了。

例子

 代码如下 复制代码

<?php
class SqlTool{
private $conn;
private $host=”localhost”;
private $user=”root”;
private $password=”";
private $db=”bbs”;
function sqlTool(){
$this->conn=mysql_connect(“$this->host”,”$this->user”,”$this->password”);
mysql_select_db($this->db,$this->conn);
mysql_query(“set names gbk”);
}
function executedql($sql){
$res=mysql_query($sql);
return $res;
}
function executedml($sql){
$b=mysql_query($sql);
if(!$b){
echo “操作失败”;
}else{
if(mysql_affected_rows($this->conn)>0){
echo “操作成功”;
}else{
echo “没有影响到行数”;
}
}
mysql_close($this->conn);
}
}
?>
PDO是mysql数据库操作的一个公用类了，我们不需要进行自定类就可以直接使用pdo来操作数据库了，但是在php默认配置中pdo是未开启所以我们必须先在php.ini中开启它才可以使用，下文我会讲到。

PDO扩展为PHP访问数据库定义了一个轻量级的、一致性的接口，它提供了一个数据访问抽象层，
这样，无论使用什么数据库，都可以通过一致的函数执行查询和获取数据。

PDO支持的PHP版本为PHP5.1以及更高的版本,而且在PHP5.2下PDO默认为开启状态,
下面是在php.ini中PDO的配置:

extension=php_pdo.dll

为了启用对某个数据库的支持,需要在php配置文件中将相应的扩展打开,例如要支持MySQL,需要开启下面的扩展

extension=php_pdo_mysql.dll

这里是使用PDO对mysql进行基本的增删改查操作

程序代码：

 代码如下 复制代码

header("content-type:text/html;charset=utf-8");

$dsn="mysql:dbname=test;host=localhost";
$db_user='root';
$db_pass='admin';

try{
 $pdo=new PDO($dsn,$db_user,$db_pass);
}catch(PDOException $e){
 echo '数据库连接失败'.$e->getMessage();
}

//新增
$sql="insert into buyer (username,password,email) values ('ff','123456','admin@admin.com')";
$res=$pdo->exec($sql);
echo '影响行数：'.$res;


//修改
$sql="update buyer set username='ff123' where id>3";
$res=$pdo->exec($sql);
echo '影响行数：'.$res;

//查询
$sql="select * from buyer";
$res=$pdo->query($sql);

foreach($res as $row){
 echo $row['username'].'<br/>';
}

//删除
$sql="delete from buyer where id>5";
$res=$pdo->exec($sql);
echo '影响行数：'.$res;
利用php提交员工编号给mysql，然后由mysql把数据接受并利用delete进行数据删除操作了，下面我来给大家分享几个例子。

delete 语句的示例：

 代码如下 复制代码

delete from friends where user_name = 'simaopig';

语法结构中，我们就可以看出，和 update 语法一样，我们是可以省略 where 子句的。不过这是一个很危险的行为。因为如果不指定 where 子句，delete 将删除表中所有的记录，而且是立即删除

1.删除指定编号的员工信息

 代码如下 复制代码

<html>
<head>
</head>
<body>
<center>员工信息表</center>
<table border="1" align='center'>
<thead><tr><th>编号</th><th>姓名</th><th>年龄</th></tr></thead>
<tbody>
<?php
header("Content-type:text/html; charset=utf-8");
$_SESSION['arr']=array('1'=>array('name'=>'张三','age'=>18),'2'=>array('name'=>'李四','age'=>19),'3'=>array('name'=>'王五','age'=>20));
if(!empty($_POST['num'])){
unset($_SESSION['arr'][$_POST['num']]); //删除指定id的员工信息
}
if(isset($_SESSION['arr'])){
foreach ($_SESSION['arr'] as $k => $v) {
echo "<tr><td>".($k)."</td><td>".$v['name']."</td><td>".$v['age']."</td></tr>";
}
}
 
?>
</tbody>
</table>
 
<form method='post' action=""><br>
<center>
<b>输入员工编号：</b>
<input type="text" name="num" size='5'><br>
<input type='submit' value='删除' name='sub' class='btn'>
</center>
</form>
</body>
</html>

2.员工信息批量删除例子

关键技术
本实例的关键点是while()循环语句的灵活运用。根据提交的参数值，执行while()循环语句，在循环体重执行删除操作，完成数据的循环删除操作。
设计过程
（1）创建PHP脚本文件。首先，连接MySQL数据库服务器，连接MySQL中名称为db_while的数据库，并设置页面的编码格式。然后，定义循环变量变量$a和$b，将第1层while循环中的循环条件设置为$b<$a，然后，再次利用while语句循环输出数据表中的数据，并执行数据的删除操作，其代码如下：

 代码如下 复制代码

<?php
if($_POST[sub]){ //通过POST方式获取参数
 $conn=mysql_connect("localhost","root","111"); //连接mysql数据库
 mysql_select_db("db_while",$conn); //连接数据库
 mysql_query("SET NAMES GBK");//定义编码格式
 $a=$_POST[te];//接收文本框参数
 $b=0;//定义变量
while($b<$a){//while循环
 $rs=mysql_query("select * from tb_while");//执行查询操作
 while($rst=mysql_fetch_array($rs)){//将查询结果保存在数组中
$sql="delete * from tb_while where id=$b"; //sql语句
mysql_query($sql);//执行删除操作
echo"姓名为".$rst[name]."的员工已被删除<br>";//输出被删除的员工姓名
$b++
 }
 }

}
?>

(2)将该文件存储于MR266文件夹下，命名为index.php。

操作类就是把一些常用的一系列的数据库或相关操作写在一个类中，这样调用时我们只要调用类文件，如果要执行相关操作就直接调用类文件中的方法函数就可以实现了，下面整理了一个Memcache数据缓存操作类库文件，希望对各位会有帮助了。

例子，代码如下

 代码如下 复制代码

class memcachedInit {
private $memcache;

/**
 * Memcache缓存-设置缓存
 * 设置缓存key，value和缓存时间
 * @param  string $key   KEY值
 * @param  string $value 值
 * @param  string $time  缓存时间
 */
public function set_cache($key, $value, $time = 0) {
return $this->memcache->set($key, $value, false, $time);
}

/**
 * Memcache缓存-获取缓存
 * 通过KEY获取缓存数据
 * @param  string $key   KEY值
 */
public function get_cache($key) {
return $this->memcache->get($key);
}

/**
 * Memcache缓存-清除一个缓存
 * 从memcache中删除一条缓存
 * @param  string $key   KEY值
 */
public function clear($key) {
return $this->memcache->delete($key);
}

/**
 * Memcache缓存-清空所有缓存
 * 不建议使用该功能
 * @return
 */
public function clear_all() {
return $this->memcache->flush();
}

/**
 * 字段自增-用于记数
 * @param string $key  KEY值
 * @param int    $step 新增的step值
 */
public function  increment($key, $step = 1) {
return $this->memcache->increment($key, (int) $step);
}

/**
 * 字段自减-用于记数
 * @param string $key  KEY值
 * @param int    $step 新增的step值
 */
public function decrement($key, $step = 1) {
return $this->memcache->decrement($key, (int) $step);
}

/**
 * 关闭Memcache链接
 */
public function close() {
return $this->memcache->close();
}

/**
 * 替换数据
 * @param string $key 期望被替换的数据
 * @param string $value 替换后的值
 * @param int    $time  时间值
 * @param bool   $flag  是否进行压缩
 */
public function replace($key, $value, $time = 0, $flag = false) {
return $this->memcache->replace($key, $value, false, $time);
}

/**
 * 获取Memcache的版本号
 */
public function getVersion() {
return $this->memcache->getVersion();
}

/**
 * 获取Memcache的状态数据
 */
public function getStats() {
return $this->memcache->getStats();
}

/**
 * Memcache缓存-设置链接服务器
 * 支持多MEMCACHE服务器
 * 配置文件中配置Memcache缓存服务器：
 * $InitPHP_conf['memcache'][0]   = array('127.0.0.1', '11211'); 
 * @param  array $servers 服务器数组-array(array('127.0.0.1', '11211'))
 */
public function add_server($servers) {
$this->memcache = new Memcache;
if (!is_array($servers) || empty($servers)) exit('memcache server is null!');
foreach ($servers as $val) {
$this->memcache->addServer($val[0], $val[1]);
}
}
}

使用方法

$newclass = new memcachedInit();
$newclass->getVersion() //获取版本号
$newclass->close() //关闭Memcache链接
$newclass->clear($key) //从memcache中删除一条缓存
$newclass->get_cache($key) //通过KEY获取缓存数据

上面就简单介绍了它的使用方法了，其实还有很多在这里我就不介绍了呀。

总结，这个只是一个最基于的Memcache缓存操作类了，比起像数据库缓存类操作会更好更复杂了哦，希望例子能帮助到各位朋友哦。

socket_connect函数在php默认安装是不给支持的，如果要使用它我们需要在php.ini中进行简单的开启，下面我们一起来看看吧。

linux系统中开启socket_connect方法

#cd /home/php/ext/sockets #/server/php/bin/phpize #./configure --prefix=/usr/local/php/lib --with-php-config=/server/php/bin/php-config --enable-sockets #make #make install

再修改/usr/local/php/etc/php.ini文件

#extension_dir = "/usr/local/php/lib/php/extensions/no-debug-non-zts-20090626/" (php5.4版本以上不用加扩展路径) extension=sockets.so

windows系统开启socket_connect步骤

直接修改php.ini 文件 去掉extension=PHP_sockets.dll 前面的分号


最后重启一下你的服务器环境就可以了，如iis apache nginx都可以正常使用socket_connect函数

socket_connect 说明

bool socket_connect ( resource $socket , string $address [, int $port = 0 ] )

成功时返回 TRUE， 或者在失败时返回 FALSE。

例子

 代码如下 复制代码

<?php
$address = gethostbyname ($ip);
        $command = "ping -c 1 " . $address; 
        $r = exec($command); 
          if ($r[0]=="r")
          {       
            $socket = socket_create (AF_INET, SOCK_STREAM, 0);
            if ($socket < 0) {
                echo "socket_create() failed: reason: " . socket_strerror ($socket) . "n";
            } else {
                echo "OK.n";
            }
?>
[!--infotagslink--]

相关文章

  • php svn操作类

    以前我们开发大型项目时都会用到svn来同步，因为开发产品的人过多，所以我们会利用软件来管理，今天发有一居然可以利用php来管理svn哦，好了看看吧。 代码如下 ...2016-11-25

  • PHP 数据库缓存Memcache操作类

    操作类就是把一些常用的一系列的数据库或相关操作写在一个类中，这样调用时我们只要调用类文件，如果要执行相关操作就直接调用类文件中的方法函数就可以实现了，下面整理了...2016-11-25

  • C#连接SQL数据库和查询数据功能的操作技巧

    本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧，本文通过图文并茂的形式给大家介绍的非常详细，需要的朋友参考下吧...2021-05-17

  • C#从数据库读取图片并保存的两种方法

    这篇文章主要介绍了C#从数据库读取图片并保存的方法，帮助大家更好的理解和使用c#，感兴趣的朋友可以了解下...2021-01-16

  • Intellij IDEA连接Navicat数据库的方法

    这篇文章主要介绍了Intellij IDEA连接Navicat数据库的方法,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借价值，需要的朋友可以参考下...2021-03-25

  • 在数据库里将毫秒转换成date格式的方法

    在开发过程中，我们经常会将日期时间的毫秒数存放到数据库，但是它对应的时间看起来就十分不方便，我们可以使用一些函数将毫秒转换成date格式。 一、 在MySQL中，有内置的函数from_unixtime()来做相应的转换，使用如下： 复制...2014-05-31

  • C#操作本地文件及保存文件到数据库的基本方法总结

    C#使用System.IO中的文件操作方法在Windows系统中处理本地文件相当顺手,这里我们还总结了在Oracle中保存文件的方法,嗯,接下来就来看看整理的C#操作本地文件及保存文件到数据库的基本方法总结...2020-06-25

  • 如何解决局域网内mysql数据库连接慢

    通过内网连另外一台机器的mysql服务， 确发现速度N慢！ 等了大约几十秒才等到提示输入密码。 但是ping mysql所在服务器却很快！ 想到很久之前有过类似的经验， telnet等一些服务在连接请求的时候，会做一些反向域名解析（如果...2015-10-21

  • MySQL快速复制数据库数据表的方法

    某些时候，例如为了搭建一个测试环境，或者克隆一个网站，需要复制一个已存在的mysql数据库。使用以下方法，可以非常简单地实现。假设已经存在的数据库名字叫db1，想要复制一份，命名为newdb。步骤如下：1. 首先创建新的数据库newd...2015-10-21

  • mysqldump命令导入导出数据库方法与实例汇总

    mysqldump命令的用法1、导出所有库系统命令行mysqldump -uusername -ppassword --all-databases > all.sql 2、导入所有库mysql命令行mysql>source all.sql; 3、导出某些库系统命令行mysqldump -uusername -ppassword...2015-10-21

  • Mysql数据库错误代码中文详细说明

    1005：创建表失败1006：创建数据库失败1007：数据库已存在，创建数据库失败1008：数据库不存在，删除数据库失败1009：不能删除数据库文件导致删除数据库失败1010：不能删除数据目录导致删除数据库失败1011：删除数据库...2013-09-23

  • c#异步读取数据库与异步更新ui的代码实现

    这篇文章主要介绍了c#从数据库里取得数据并异步更新ui的方法，大家参考使用吧...2020-06-25

  • Yii2.0高级框架数据库增删改查的一些操作

    yii2.0框架是PHP开发的一个比较高效率的框架，集合了作者的大量心血，下面通过用户为例给大家详解yii2使用中的一些基本的增删改查操作。 User::find()->all(); //返回所有用户数据； User::findOne($id); //返回 主键...2015-11-24

  • MYSQL数据库使用UTF-8中文编码乱码的解决办法

    1.用phpmyadmin创建数据库和数据表 创建数据库的时候，请将“整理”设置为：“utf8_general_ci” 或执行语句： 复制代码 代码如下:CREATE DATABASE `dbname` DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci; 创...2015-10-21

  • springBoot 项目排除数据库启动方式

    这篇文章主要介绍了springBoot 项目排除数据库启动方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2021-09-10

  • Linux 下使用shell脚本定时维护数据库的案例

    这篇文章主要介绍了Linux 下使用shell脚本定时维护数据库，本文通过案例分析给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-07-11

  • node.js如何操作MySQL数据库

    这篇文章主要介绍了node.js如何操作MySQL数据库，帮助大家更好的进行web开发，感兴趣的朋友可以了解下...2020-10-29

  • PHP连接公司内部服务器的MYSQL数据库的简单实例

    “主机，用户名，密码”得到连接、“数据库，sql，连接”得到结果，最后是结果的处理显示。当然，数据库连接是扩展库为我们完成的，我们能做的仅仅是处理结果而已。...2013-09-29

  • C#连接加密的Sqlite数据库的方法

    对数据加密分两种，一种是对数据库本身进行加密，另一种是对数据表中的数据进行加密，下面通过本文给大家介绍C#连接加密的Sqlite数据库的方法，感兴趣的朋友一起看看吧...2020-06-25

  • Java连接数据库oracle中文乱码解决方案

    这篇文章主要介绍了Java连接数据库oracle中文乱码解决方案,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-05-16