首页 / MYSQL / mysql数据库封装

mysql数据库封装

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mysql数据库封装，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9637字，纯文字阅读大概需要14分钟。

内容图文

<?php

/**
 * name: sql操作封装，可扩展 .
 * User: 张云山
 * Date: 2016/9/4
 * Time: 22:02
 */

//php文件编码设置
header(‘Content-type: text/html; charset=utf-8‘);
//数据库类
class sqled {
    public function addTabase($sql_url,$sql_name,$sql_pss,$sql_DB){//创建数据库
        $conn = new mysqli($sql_url,$sql_name,$sql_pss);
        if(!$conn){
            echo "连接失败<br>";
        };
        $sql = "CREATE DATABASE ".$sql_DB;
        if($conn->query($sql) == TRUE){
            return true;
        }else{
            echo $conn->error."<br>";
        };
        $conn -> close();
    }
    //示例（创建数据库）************///  addTabase($sql_url,$sql_name,$sql_pss,$sql_DB);
    ///*************************************************************************///


    public function addTable($sql_url,$sql_name,$sql_pss,$sql_DB,$data){//创建表以及字段
        $conn = new mysqli($sql_url,$sql_name,$sql_pss,$sql_DB);
        // 检测连接
        if (!$conn) {
            echo "连接失败";
        };
        $sql = "CREATE TABLE {$data[‘name‘]} (
            id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
            {$data[‘data‘]}
        )";
        /*
          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){
            return true;
        }else{
            echo $conn->error."<br>";
        };
        $conn -> close();
    }
    //示例（创建表以及字段）************///  addTable($sql_url,$sql_name,$sql_pss,$sql_DB,array("name"=>"ceshi_biao","data"=>"
    //                              test VARCHAR(30) NOT NULL
    //                         "));
    //***************************************************************************************///



    public function addDB($sql_url,$sql_name,$sql_pss,$sql_DB,$data){//添加字段数据
        $conn = new mysqli($sql_url,$sql_name,$sql_pss,$sql_DB);
        if(!$conn){
            echo "连接失败";
        };
        $sql = "INSERT INTO {$data[‘name‘]} (
          {$data["key"]}
        )
        VALUES (
          {$data[‘value‘]}
        )";
        if($conn->query($sql) == TRUE){
            return true;
        }else{
            echo $conn->error;
        };
        $conn -> close();
    }
    //示例（添加字段数据）************///  addDB($sql_url,$sql_name,$sql_pss,$sql_DB,array(
    //                         "name"=>"ceshi_biao",
    //                         "key"=>"zanIndex",
    //                         "value"=>"0",
    //));
    ///***********************************************************************************///



    public function queryDB($sql_url,$sql_name,$sql_pss,$sql_DB,$data){//读取数据
        // 创建连接
        $conn = new mysqli($sql_url,$sql_name,$sql_pss,$sql_DB);
        // 检测连接
        if ($conn->connect_error) {
            die("连接失败: " . $conn->connect_error);
        };
        $sql = "SELECT {$data[‘data‘]} FROM {$data[‘name‘]}";
        $result = $conn->query($sql);
        if ($result->num_rows > 0) {
            // 输出每行数据
            $data_data = explode(",",$data[‘data‘]);
            $key = ‘{‘;
            $fh = ‘,‘;
            for($i = 0 ; $i < count($data_data) ; $i++){
                if($i == count($data_data)-1){
                    $fh = ‘‘;
                };
                $key = $key.‘"‘.$data_data[$i].‘":"$row[\‘‘.$data_data[$i].‘\‘]"‘.$fh;
            };
            $key = $key.‘}‘;
            $returnData = array();
            while($row = $result->fetch_assoc()) {
                $key1 = json_decode($key,true);
                foreach($key1 as $keyName=>$value){
                    $value =  "{".$value."}";
                    eval("\$value = \"$value\";");
                    $key1[$keyName] = $value;
                };
                array_push($returnData,$key1);
            };
//            echo $returnData;//执行回调，并返回查询结果
        } else {
            echo "0 个结果";
        };
        return $returnData;
        $conn->close();
    }
    //示例（数据读取或数据查询）************///  queryDB($sql_url,$sql_name,$sql_pss,$sql_DB,array(
    //                         "name" => "ceshi_biao",
    //                         "data" => "id,zanIndex",
    //                     ));
    //******************************************************************///



    public function updateDB($sql_url,$sql_name,$sql_pss,$sql_DB,$data){//数据更新
        $con=mysqli_connect($sql_url,$sql_name,$sql_pss,$sql_DB);
        // 检测连接
        if (mysqli_connect_errno())
        {
            echo "连接失败: " . mysqli_connect_error();
        };
        $sqlUpdate_set = null;
        $sqlUpdate_WHERE = null;
        //无条件设置，全部更新
        $index = 0;
        $fh = ",";
        foreach ($data[‘newdata‘] as $key => $value){
            $index += 1;
            if($index == count($data[‘newdata‘])){
                $fh = null;
            };
            $sqlUpdate_set = $sqlUpdate_set.$key."=‘".$value."‘".$fh;
        };
        //有条件限制s
        if(count($data["data"]) > 0 ){
            $sqlUpdate_WHERE = "WHERE";
            $fh1 = "AND";
            $index1 = 0;
            foreach ($data["data"] as $key=>$value){
                $index1 += 1;
                if($index1 == count($data[‘data‘])){
                    $fh1 = null;
                };
                $sqlUpdate_WHERE = $sqlUpdate_WHERE." ".$key."=‘".$value."‘".$fh1;
            };
        };
        //有条件限制e
        mysqli_query($con,"UPDATE {$data[‘name‘]} SET ".$sqlUpdate_set.$sqlUpdate_WHERE);
        mysqli_close($con);
        return true;
    }
    //示例(数据更新)************///  updateDB($sql_url,$sql_name,$sql_pss,$sql_DB,array(
    //                         "name"=>"ceshi_biao",
    //                         "newdata" => array(
    //                             "zanIndex"=>"豆腐干发给豆腐",
    //                             "id"=>"1",
    //                         ),
    //                         "data"=> array()//条件
    //                     ));
    //*****************************************************************///



    public function deleteDB($sql_url,$sql_name,$sql_pss,$sql_DB,$data){//数据删除
        $con=mysqli_connect($sql_url,$sql_name,$sql_pss,$sql_DB);
        // 检测连接
        if (mysqli_connect_errno())
        {
            echo "连接失败: " . mysqli_connect_error();
        };
        $result = mysqli_query($con,"DELETE FROM {$data[‘name‘]} WHERE {$data[‘data‘]}");
        echo $result;
        mysqli_close($con);
        return true;
    }
    //示例(数据删除)************///  deleteDB($sql_url,$sql_name,$sql_pss,$sql_DB,array(
    //                         "name"=>"ceshi_biao",
    //                     ));
    //*********************************************************************************//


    //数据初始值赋值
    public function aab($a,$b){
        if($a){
            $a = $a;
        }else{
            $a = $b;
        };
        return $a;
    }
    //*********************************************************************************//


    //数据库操作类型
    public static $sql_type = array(
        "addTabase"=>"addTabase",//创建数据库
        "addTable"=>"addTable",//创建表以及字段
        "addDB"=>"addDB",//添加字段数据
        "queryDB"=>"queryDB",//读取数据
        "updateDB"=>"updateDB",//数据更新
        "deleteDB"=>"deleteDB"//数据删除
    );
    //*********************************************************************************//

    //sql综合调用方法；
    public function fn($sql){
        $sql[‘type‘] = $this->aab($sql[‘type‘],sqled::$sql_type[‘queryDB‘]);//默认数据库操作设置为（数据查询）
        $sql[‘url‘] = $this->aab($sql[‘url‘],"127.0.0.1");
        $sql[‘name‘] = $this->aab($sql[‘name‘],"root");
        $sql[‘pss‘] = $this->aab($sql[‘pss‘],"admin");
        $sql[‘db‘] = $this->aab($sql[‘db‘],"");
        $sql[‘table‘] = $this->aab($sql[‘table‘],"");
        $sql[‘array‘] = $this->aab($sql[‘array‘],array());
        switch ($sql[‘type‘]){
            case "addTabase";//创建数据库
                return $this->addTabase($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘]);
                break;
            case "addTable";//创建表以及字段
                return $this->addTable($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘],$sql[‘array‘]);
                break;
            case "addDB";//添加字段数据
                return $this->addDB($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘],$sql[‘array‘]);
                break;
            case "queryDB";//读取数据
                return $this->queryDB($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘],$sql[‘array‘]);
                break;
            case "updateDB";//数据更新
                return $this->updateDB($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘],$sql[‘array‘]);
                break;
            case "deleteDB";//数据删除
                return $this->deleteDB($sql[‘url‘],$sql[‘name‘],$sql[‘pss‘],$sql[‘db‘],$sql[‘array‘]);
                break;
        }
    }
    //示例(sql操作)*****************///
        //$sql = new sqled();
        //$q =  $sql->fn(array(
        //    "db"=>sql_db,
        //    ‘type‘=>sqled::$sql_type[‘deleteDB‘],
        //    "array"=>array(
        //        "name"=>"user",
        //        "data"=>"id",
        //        "newdata"=>array(
        //            "id"=>"5",
        //            "user" => "new-d"
        //        )
        //    )
        //));
    ///******************************************************************************//


};

mysql数据库封装

标签：

本文系统来源：http://www.cnblogs.com/zys8119/p/5840514.html

内容总结

以上是互联网集市为您收集整理的mysql数据库封装全部内容，希望文章能够帮你解决mysql数据库封装所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/468395.html

来源：【匿名】

【上一篇】浅谈mysql主从复制的高可用解决方案【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【mysql数据库封装】教程文章相关的互联网学习教程文章

从入门到自闭之Python--MySQL数据库的单表操作【代码】

单表查询：select * from 表 where 条件 group by 分组 having 过滤 order by 排序 limit n;语法：select distinct 字段1，字段2... from 表名 where 条件 group by 组名 having 筛选 order by 排序 limit 限制条数找到表:from拿着where指定的约束条件，去文件/表中取出一条条记录将取出的一条条记录进行分组group by，如果没有group by，则整体作为一组执行select（去重）：select * from 表名;将分组的结果进行having过滤将结果按...

备份mysql数据库【图】

使用navicate 使用命令备份mysqldump -hlocalhost -uroot -prootdatabases > C:\Users\asus008\Desktop\mp4\databases.sql还原mysql -hlocalhost -uroot -proot databases < C:\Users\asus008\Desktop\mp4\databases.sql备份多个数据库mysqldump -hlocalhost -uroot -proot --databases oa tele > C:\Users\asus008\Desktop\mp4\databasesf.sql备份所有数据库mysqldump --all -databases -hlocalhost -uroot -proot > C:\Users\as...

Ubuntu下取消MySQL数据库本机绑定限制方法

出现问题：在Ubuntu系统中，添加了MySQL账户，赋予了数据库完全操作权限，并且允许数据库从外部链接但是，还是无法远程访问MySQL数据库。原因：Ubuntu系统中，默认安装的MySQL限制了只有本机才能访问数据库解决办法：取消MySQL数据库的本机绑定限制nano /etc/mysql/my.cnf #编辑配置文件找到bind-address = 127.0.0.1改为#bind-address = 127.0.0.1ctrl+o #保存配置ctrl+x #退出/etc/init.d/mysql restart #重启数据库现在已经可以...

MySQL数据库web维护管理软件【图】

TreeSoft数据库管理系统使用JAVA开发，采用稳定通用的springMVC +JDBC架构，实现基于WEB方式对 MySQL，Oracle，PostgreSQL 等数据库进行维护管理操作。功能包括：数据库的展示,库表的展示，表字段结构的展示， SQL语句的在线编辑批量执行，表结构的在线设计维护，数据的在线编辑维护，查询语句保存，JSON数据格式化，SQL语法帮助，在线数据源选择配置等。系统内置14套UI皮肤，45套代码编辑区UI方案，使用中可以依个人喜好选择配...

mysql数据库相关基础知识01【代码】

数据库的简介1.什么是数据库：数据仓库。访问必须只能用SQL语句来访问。数据库也是一个文件的系统。 2.数据库的作用：存储数据的作用。开发任何的应用，都有数据库。 3.关系型的数据库：数据库中保存的都是实体与实体之间的关系。 4.常见的数据库* Java开发，必用的两个数据库Oracle和MySQL* Oracle数据库（甲骨文）大型的数据库，收费的。* MySQL数据库小型的数据库，免费开源的。被Oracle收购了（在6.x版本下开始收费了）*...

python连接mysql数据库

1.系统必须安装MySQL-python软件，否则python没有连接的模块(在Linux系统)yum install MySQL-python2.安装mysql数据库yum install mysql-server mysql[root@AY140528120357495c4bZ ~]# /etc/init.d/mysqld restartStopping mysqld: [ OK ]Starting mysqld: [ OK ][root@AY140528120357495c4bZ ~]#3.在mysql中创建数据库和表[root@AY1405...

配置MySQL数据库【图】

一、配置MySQL数据库1、解压绿色版mysql，如下图二、安装服务1、运行cmd（管理员版本，否则没有权限），如下图 2、运行命令mysqld –install安装服务，如下图：如果不需要mysql里，只需要运行mysqld –remove即可移除，如下图 3、运行net start mysql 启动服务，如下图如需要配置是否开机启动mysql可以在windows服务里面配置。三、客户端测试1、mysql –uroot –p 如下图四、配置编码为UTF-81、在mysql5.6的根目录下，复制my-d...

MYSQLshu数据库学习----查询

查询语句是MYSQL数据库中用到的最多的语句。查询语句分为几种单表查询集合函数查询连接查询子查询合并查询正则表达式查询一：单表查询SELECT 属性 FROM 表名 [WHERE 查询条件][GROUP BY 属性名1 [HAVING 分组条件]][ORDER BY 属性2 [ASC/DESC]][LIMIT];WHERE 查询条件查询条件符号或关键字例子比较=、<、<=、>、>=、!=、<>、!>、!<WHERE ID = 1指定范围BETWEEN AND、NOT BETWEEN ANDWHERE ID BETWEEN 2 AND 3指定集合IN、NOT INWH...

MYSQL数据库导入数据时出现乱码的解决办法

首先在新建数据库时一定要注意生成原数据库相同的编码形式，如果已经生成可以用phpmyadmin等工具再整理一次，防止数据库编码和表的编码不统一造成乱码。方法一: 通过增加参数 –default-character-set = utf8 解决乱码问题mysql -u root -p password < path_to_import_file –default-character-set = utf8 方法二: 在命令行导入乱码解决1. use database_name; 2. set names utf8; (或其他需要的编码) 3. source example.sql (sql...

mysql数据库表格导出为excel表格【代码】

在本地数据库中操作如下：由于excel表格的编码是GBK，所以导出时要加一个设置字符编码；select*from 某个表 into outfile ‘d:/文件名.xls‘CHARACTERSET gbk; 原文：http://www.cnblogs.com/luwenjie110/p/4336988.html

如何设置才能远程登录Mysql数据库【代码】【图】

可以在一台机器上访问另一台机器的MySQL，但是需要一些设置。进入MySQL后，输入以下命令： GRANT ALL PRIVILEGES ON *.* TO ‘tigase‘@‘%‘ IDENTIFIED BY ‘123456‘ WITH GRANT OPTION;允许任何主机以tigase为用户名（root用户不能远程登录，只能本地登录），123456为密码访问MySQL。flush privileges;让MySQL重新加载权限，使赋予的权限能够马上生效。原文：http://www.jb51.net/article/54407.htm

linux下如何实现mysql数据库每天自动备份定时备份【代码】【图】

概述??备份是容灾的基础，是指为防止系统出现操作失误或系统故障导致数据丢失，而将全部或部分数据集合从应用主机的硬盘或阵列复制到其它的存储介质的过程。而对于一些网站、系统来说，数据库就是一切，所以做好数据库的备份是至关重要的！备份是什么？为什么要备份容灾方案建设存储介质光盘磁带硬盘磁盘阵列 DAS：直接附加存储 NAS：网络附加存储 SAN：存储区域网络云存储这里主要以本地磁盘为存储介质讲一下计划任务的...

ThinkPHP学习（三）配置PHP5支持MySQL，连接MySQL数据库【图】

配置PHP5支持MySQL打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension=php_mysql.dll”，把前面的分号去掉，保存文件，启动服务；却提示“PHP startup: Unable to load dynamic library :F:\PHP\php_mysql.dll”错误，解决办法，打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension_dir = "ext"”，把前面的分号去掉，保存文件，启动服务，问题解决；准备测试数据如果你还没有安装MySQL，请先安装MyS...

全网最全一篇MySQL数据库MVCC详解，不全你打我【图】

什么是MVCC全称Multi-Version Concurrency Control，即多版本并发控制，主要是为了提高数据库的并发性能。以下文章都是围绕InnoDB引擎来讲，因为myIsam不支持事务。同一行数据平时发生读写请求时，会上锁阻塞住。但mvcc用更好的方式去处理读—写请求，做到在发生读—写请求冲突时不用加锁。这个读是指的快照读，而不是当前读，当前读是一种加锁操作，是悲观锁。那它到底是怎么做到读—写不用加锁的，快照读和当前读又是什么鬼，跟着...

Spring Batch示例: 读取CSV文件并写入MySQL数据库【代码】

Spring Batch示例: 读取CSV文件并写入MySQL数据库GitHub版本: https://github.com/kimmking/SpringBatchReferenceCN/blob/master/01_introduction/Spring_Batch_MySQL.md原文链接: Reading and writing CVS files with Spring Batch and MySQL原文作者: Steven Haines - 技术架构师下载本教程的源代码: SpringBatch-CSV演示代码用批处理程序来操作动辄上GB的数据很可能会拖死整个系统,但现在我们可以通过Spring Batch将其拆解为多...

首页 / MYSQL / mysql数据库封装

mysql数据库封装

内容导读

内容图文

内容总结

内容备注

内容手机端

【mysql数据库封装】教程文章相关的互联网学习教程文章

从入门到自闭之Python--MySQL数据库的单表操作【代码】

备份mysql数据库【图】

Ubuntu下取消MySQL数据库本机绑定限制方法

MySQL数据库web维护管理软件【图】

mysql数据库相关基础知识01【代码】

python连接mysql数据库

配置MySQL数据库【图】

MYSQLshu数据库学习----查询

MYSQL数据库导入数据时出现乱码的解决办法

mysql数据库表格导出为excel表格【代码】

如何设置才能远程登录Mysql数据库【代码】【图】

linux下如何实现mysql数据库每天自动备份定时备份【代码】【图】

ThinkPHP学习（三）配置PHP5支持MySQL，连接MySQL数据库【图】

全网最全一篇MySQL数据库MVCC详解，不全你打我【图】

Spring Batch示例: 读取CSV文件并写入MySQL数据库【代码】

MYSQL - 相关标签

数据库 - 相关标签

封装 - 相关标签

MYSQL - 技术教程分类

MYSQL - 最新教程

MYSQL - 最热教程