勤奋鸟旗下 软件定制开发 安全交付平台!一次合作,终身售后!全程项目经理一对一跟进测试!公司以自研团队结合搭档圈,为用户提供安全快速稳定的软件源码开发服务!

Mysqli,PDO,链接数据库

2024-09-04 17:20:51
复制链接

1879

Mysql PDO 源生PHP SQL语句

用PHPMYSQLi和PDO两种方式链接数据库,用SQL语句来操作数据库

<?php //&#35774;&#32622;PHP&#25991;&#20214;&#32534;&#30721;
header("content-type:text/html;charset=utf-8");
//&#35774;&#32622;&#38169;&#35823;&#32423;&#21035;
error_reporting(E_ALL);
class mysqlPDOManage
{
    public $msg = "";    //&#25805;&#20316;&#20449;&#24687;
    public $conn = null; //&#25968;&#25454;&#24211;&#36830;&#25509;

    /*
     * &#26041;&#27861;&#21517;&#65306;getMessage()
     * &#21151;&#33021;&#65306;&#21019;&#24314;&#25253;&#38169;&#31995;&#32479;
     * &#21442;&#25968;&#65306;@string $msg &#20449;&#24687; &#65292; @bool $flag &#26631;&#24535;&#65306;&#22914;&#26524;&#26159;true&#34920;&#31034;&#25104;&#21151;&#20449;&#24687;&#65292;&#22914;&#26524;&#26159;false&#34920;&#31034;&#22833;&#36133;&#20449;&#24687;
     * &#36820;&#22238;&#20540;&#65306;&#26080;
     */
    public function getMessage($msg, $flag = false)
    {
        if ($flag) {
            $this->msg .= "<div style="font-size:12px;color:green">{$msg}</div>";
        } else {
            $this-&gt;msg .= "<div style="font-size:12px;color:red">{$msg}</div>";
        }
    }

    /*
    * &#26041;&#27861;&#21517;&#65306;__construct();
    * &#21151;&#33021;&#65306;&#26500;&#36896;&#26041;&#27861;&#65292;&#21021;&#22987;&#21270;&#25968;&#25454;&#24211;&#36830;&#25509;&#65292;pdo&#38142;&#25509;&#21487;&#20197;&#38142;&#25509;&#20219;&#24847;&#25968;&#25454;&#24211;&#27604;&#22914;sql server .....
    * &#21442;&#25968;&#65306;
     *  @string $type &#25968;&#25454;&#24211;&#31867;&#22411;
     *  @int    $port &#31471;&#21475;&#21495;
    *   @string $host &#20027;&#26426;&#22320;&#22336;
    *   @string $username &#29992;&#25143;&#21517;
    *   @string $password &#23494;&#30721;
    *   @string $dbName &#25968;&#25454;&#24211;&#21517;&#31216;
    *   @string $charset &#32534;&#30721;
    * &#36820;&#22238;&#20540;&#65306;&#22833;&#36133;&#36820;&#22238;false &#65292;&#25104;&#21151;&#26080;&#36820;&#22238;&#20540;
    */
    public function __construct($host, $dbName, $username='root', $password='root', $charset = 'utf8', $type = 'mysql',$port=3306)
    {
        try{
            $this-&gt;conn = @new PDO("{$type}:host={$host};dbname={$dbName};port={$port};charset={$charset}",$username,$password);
            $this-&gt;getMessage("&#36830;&#25509;&#25968;&#25454;&#24211;&#26381;&#21153;&#22120;{$host}:{$port}&#25104;&#21151;&#65292;&#36873;&#25321;&#25968;&#25454;&#24211;{$dbName}&#25104;&#21151;&#65292;&#35774;&#32622;&#36830;&#25509;&#32534;&#30721;{$charset}&#25104;&#21151;&#12290;",true);
        }catch(PDOException $e){
            $err = iconv('gbk','utf-8',$e-&gt;getMessage());
            $this-&gt;getMessage("&#36830;&#25509;&#25968;&#25454;&#24211;{$host}:{$port}&#22833;&#36133;&#65292;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
            return false;
        }
    }
    /*
     * &#26041;&#27861;&#21517;&#65306;exec();
     * &#21151;&#33021;&#65306;&#25191;&#34892;&#22686;&#21024;&#25913;&#25805;&#20316;
     * &#21442;&#25968;&#65306;@string $sql &#35821;&#21477;
     * &#36820;&#22238;&#20540;&#65306;&#25191;&#34892;&#25104;&#21151;&#36820;&#22238;true&#65292;&#25191;&#34892;&#22833;&#36133;&#36820;&#22238;false
     */
    public function exec($sql){
        //01 &#21028;&#26029;&#26159;&#21542;&#26159;&#22686;&#21024;&#25913;&#25805;&#20316;
        if(preg_match('/^(insert|update|delete)/i',trim($sql))) {
            //02 &#25191;&#34892;&#22686;&#21024;&#25913;&#25805;&#20316;,&#25104;&#21151;&#36820;&#22238;true&#65292;&#22833;&#36133;&#36820;&#22238;false
            $res = $this-&gt;conn-&gt;exec($sql);
            //03 &#21028;&#26029;&#22686;&#21024;&#25913;&#25805;&#20316;&#26159;&#21542;&#25104;&#21151;
            if($res !== false){
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#25104;&#21151;&#65292;".$res."&#34892;&#25968;&#25454;&#21463;&#21040;&#24433;&#21709;",true);
                return true;
            }else{
                $err = "[".$this-&gt;conn-&gt;errorCode()."] ".$this-&gt;conn-&gt;errorInfo()[2];
                $err = iconv('gbk','utf-8',$err);
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
                return false;
            }
        }else{
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".__function__."()&#26041;&#27861;&#21482;&#33021;&#25191;&#34892;&#22686;&#21024;&#25913;&#25805;&#20316;&#65292;&#35831;&#26816;&#26597;&#24744;&#30340;SQL&#35821;&#21477;&#65292;&#35843;&#25972;&#21518;&#20877;&#35797;&#12290;");
            return false;
        }
    }
    /*
     * &#26041;&#27861;&#21517;&#65306;getOneData();
     * &#21151;&#33021;&#65306;&#33719;&#24471;&#21333;&#26465;&#25968;&#25454;
     * &#21442;&#25968;&#65306;@string $sql &#35821;&#21477;
     * &#36820;&#22238;&#20540;&#65306;&#25191;&#34892;&#25104;&#21151;&#36820;&#22238;&#19968;&#32500;&#25968;&#32452;&#65292;&#25191;&#34892;&#22833;&#36133;&#36820;&#22238;false
     */
    public function getOneData($sql){
        //&#26816;&#27979;SQL&#35821;&#21477;&#26159;&#21542;&#26159;&#26597;&#35810;&#35821;&#21477;
        if(preg_match('/^(select)/i',trim($sql))){
            //&#25191;&#34892;SQL&#35821;&#21477;
            $res = $this-&gt;conn-&gt;query($sql);
            if($res !== false){
                //&#25972;&#29702;&#25968;&#25454;
                $arr = $res-&gt;fetch(PDO::FETCH_ASSOC);
                if( $res-&gt;fetch(PDO::FETCH_ASSOC)){
                    $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".__function__."()&#26041;&#27861;&#21482;&#33021;&#25191;&#34892;&#26597;&#35810;&#19968;&#26465;&#25968;&#25454;&#30340;&#25805;&#20316;&#65292;&#22914;&#24819;&#26597;&#35810;&#22810;&#26465;&#25968;&#25454;&#35831;&#20351;&#29992;getMoreData()&#23454;&#29616;&#65292;&#35831;&#26816;&#26597;&#24744;&#30340;SQL&#35821;&#21477;&#65292;&#35843;&#25972;&#21518;&#20877;&#35797;&#12290;");
                    return false;
                }else{
                    $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#25104;&#21151;&#12290;",true);
                    $res = null;
                    return $arr;
                }
            }else{
                $err = "[".$this-&gt;conn-&gt;errorCode()."] ".$this-&gt;conn-&gt;errorInfo()[2];
                $err = iconv('gbk','utf-8',$err);
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
                return false;
            }
        }else{
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".__function__."()&#26041;&#27861;&#21482;&#33021;&#25191;&#34892;&#26597;&#35810;&#25805;&#20316;,&#35831;&#26816;&#26597;&#24744;&#30340;SQL&#35821;&#21477;&#65292;&#35843;&#25972;&#21518;&#20877;&#35797;&#12290;");
            return false;
        }
    }

    /*
     * &#26041;&#27861;&#21517;&#65306;getMoreData();
     * &#21151;&#33021;&#65306;&#33719;&#24471;&#22810;&#26465;&#25968;&#25454;
     * &#21442;&#25968;&#65306;@string $sql &#35821;&#21477;
     * &#36820;&#22238;&#20540;&#65306;&#25191;&#34892;&#25104;&#21151;&#36820;&#22238;&#19968;&#32500;&#25968;&#32452;&#65292;&#25191;&#34892;&#22833;&#36133;&#36820;&#22238;false
     */
    public function getMoreData($sql){
        //&#26816;&#27979;SQL&#35821;&#21477;&#26159;&#21542;&#26159;&#26597;&#35810;&#35821;&#21477;
        if(preg_match('/^(select)/i',trim($sql))){
            //&#25191;&#34892;SQL&#35821;&#21477;
            $res = $this-&gt;conn-&gt;query($sql);
            if($res !== false){
                //&#25972;&#29702;&#25968;&#25454;
                $arr = $res-&gt;fetchAll(PDO::FETCH_ASSOC);

                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#25104;&#21151;&#12290;",true);
                unset($res);
                return $arr;

            }else{
                $err = "[".$this-&gt;conn-&gt;errorCode()."] ".$this-&gt;conn-&gt;errorInfo()[2];
                $err = iconv('gbk','utf-8',$err);
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
                return false;
            }
        }else{
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".__function__."()&#26041;&#27861;&#21482;&#33021;&#25191;&#34892;&#26597;&#35810;&#25805;&#20316;,&#35831;&#26816;&#26597;&#24744;&#30340;SQL&#35821;&#21477;&#65292;&#35843;&#25972;&#21518;&#20877;&#35797;&#12290;");
            return false;
        }
    }
    /*
    * &#26041;&#27861;&#21517;&#65306;getMoreData();
    * &#21151;&#33021;&#65306;&#33719;&#24471;&#22810;&#26465;&#25968;&#25454;
    * &#21442;&#25968;&#65306;@string $sql &#35821;&#21477;
    * &#36820;&#22238;&#20540;&#65306;&#25191;&#34892;&#25104;&#21151;&#36820;&#22238;&#19968;&#32500;&#25968;&#32452;&#65292;&#25191;&#34892;&#22833;&#36133;&#36820;&#22238;false
    */
    public function getMoreDataStamat($sql){
        //&#26816;&#27979;SQL&#35821;&#21477;&#26159;&#21542;&#26159;&#26597;&#35810;&#35821;&#21477;
        if(preg_match('/^(select)/i',trim($sql))){
            //&#25191;&#34892;SQL&#35821;&#21477;
            $res = $this-&gt;conn-&gt;query($sql);
            if($res !== false){
                //&#25972;&#29702;&#25968;&#25454;
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#25104;&#21151;&#12290;",true);
                return $res;

            }else{
                $err = "[".$this-&gt;conn-&gt;errorCode()."] ".$this-&gt;conn-&gt;errorInfo()[2];
                $err = iconv('gbk','utf-8',$err);
                $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
                return false;
            }
        }else{
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".__function__."()&#26041;&#27861;&#21482;&#33021;&#25191;&#34892;&#26597;&#35810;&#25805;&#20316;,&#35831;&#26816;&#26597;&#24744;&#30340;SQL&#35821;&#21477;&#65292;&#35843;&#25972;&#21518;&#20877;&#35797;&#12290;");
            return false;
        }
    }
    /*
     * &#26041;&#27861;&#21517;&#65306;getTabelRows();
     * &#21151;&#33021;&#65306;&#33719;&#21462;&#25351;&#23450;&#25968;&#25454;&#30340;&#34892;&#25968;
     * &#21442;&#25968;&#65306;@string $table &#34920;&#21517; &#65292;$where &#26465;&#20214;
     * &#36820;&#22238;&#20540;&#65306;&#25191;&#34892;&#25104;&#21151;&#36820;&#22238;&#34892;&#25968;&#65288;int&#65289;&#65292;&#25191;&#34892;&#22833;&#36133;&#36820;&#22238;false
     */
    public function getTableRows($table,$where = true){
        $sql ="select count(*) as c from {$table} where {$where}";
        $res = $this-&gt;conn-&gt;query($sql);
        if($res !== false){
            $count =$res-&gt;fetch(PDO::FETCH_ASSOC);
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#25104;&#21151;",true);
            unset($res);
            return $count['c'];
        }else{
            $err = "[".$this-&gt;conn-&gt;errorCode()."] ".$this-&gt;conn-&gt;errorInfo();
            $err = iconv('gbk','utf-8',$err);
            $this-&gt;getMessage("&#25191;&#34892;\"{$sql}\"&#22833;&#36133;&#12290;&#22833;&#36133;&#21407;&#22240;&#65306;".$err);
            return false;
        }
    }
    /*
     * &#26041;&#27861;&#21517;&#65306;closeDB();
     * &#21151;&#33021;&#65306;&#20851;&#38381;&#25968;&#25454;&#24211;
     * &#21442;&#25968;&#65306;&#26080;
     * &#36820;&#22238;&#20540;&#65306;&#26080;
     */
    public function closeDB(){
        $this-&gt;getMessage("&#20851;&#38381;&#25968;&#25454;&#24211;&#25104;&#21151;",true);
        unset($this-&gt;conn);
    }
    /*
     * &#26041;&#27861;&#21517;&#65306;__destruct();
     * &#21151;&#33021;&#65306;&#37322;&#25918;&#36164;&#28304;
     * &#21442;&#25968;&#65306;&#26080;
     * &#36820;&#22238;&#20540;&#65306;&#26080;
     */
    public function __destruct(){
        unset($this-&gt;msg);
    }


}
17330196230 13230981129

多线程同步开发
项目经理1v1跟进
源码定制交付
一次合作/终身售后

微信扫码登录/注册

提示

您的诉求已经提交请等待工作人员联系,快速通过请联系管理员

微信扫一扫快速联系

用户协议

欢迎访问我们的网站!我们非常重视用户的隐私权和信息安全,因此制定了以下用户协议,以明确我们与您之间的关系以及您在使用本网站时应遵守的条款。请您仔细阅读并同意本协议的所有条款,以便您能够合法、安全地使用本网站。如果您不同意本协议的任何内容,请立即停止使用本网站。

  1. 服务说明:本网站是一个提供定制软件开发服务和在线找技术搭档的互联网平台。我们保留随时更改、更新或暂停本网站的权利。我们会尽力确保网站的正常运行,但对于因技术问题、系统维护或其他原因导致的网站暂时不可用,我们不承担任何责任。

  2. 用户注册:用户需要通过提供手机号、微信扫码和其他必要信息来注册一个账户。您有责任保护您的用户名和密码,不得将其透露给任何第三方。对于因您的用户名和密码被泄露而导致的任何损失或损害,我们将不承担责任。

  3. 用户行为规范:用户应遵守中华人民共和国相关法律法规,不得发布或传播违法信息、侵犯他人权益的内容。用户应对其发布的内容负责,并承担因发布不当内容而引起的任何法律责任。

  4. 版权声明:本网站所包含的所有文字、图片、音频、视频等素材的著作权均归本网站所有(会员用户上传的默认承诺为不侵权的合法自有技术成果,本网站审核信息后可展示,所有权不归本网站)。未经本网站书面许可,任何单位或个人不得以任何形式复制、转载、修改或传播本网站的任何内容。对于侵犯本网站知识产权的行为,将依法追究其法律责任。

  5. 免责声明:本网站不对因使用本网站而引起的任何直接、间接、偶然、特殊或后果性的损害承担责任。包括但不限于利润损失、数据丢失、业务中断等。

  6. 适用法律和争议解决:本协议的签订、履行、解释及争议解决均适用中华人民共和国法律。如发生争议,双方应首先协商解决;协商不成的,任何一方均有权向有管辖权的人民法院提起诉讼。

  7. 本协议的解释权归本网站所有。如有未尽事宜,本网站保留最终解释权。

  8. 本协议自用户点击“同意”或“接受”按钮时生效。

同意

隐私政策

欢迎访问我们的网站!我们致力于为您提供一个安全、可靠的在线环境。本隐私政策旨在说明我们在您使用我们的网站时如何收集、使用和保护您的个人信息。请仔细阅读以下内容,以了解我们的隐私政策。

  1. 信息收集

在使用我们的网站时,我们可能会收集以下类型的信息:

a) 个人识别信息:如姓名、电子邮件地址、电话号码等。 b) 非个人识别信息:如浏览器类型、操作系统、设备类型、IP地址等。 c) 用户行为信息:如访问页面、点击链接、搜索查询等。

  1. 信息使用

我们收集的信息将用于以下目的:

a) 提供、改进和个性化我们的服务。 b) 与您联系,回应您的询问和请求。 c) 发送您请求的或我们认为对您有帮助的信息。 d) 进行市场调研和分析,以改进我们的产品和服务。 e) 防止欺诈和其他非法活动。

  1. 信息共享

我们不会出售、出租或以其他方式与第三方共享您的个人信息,除非:

a) 获得您的明确同意。 b) 与可信赖的合作伙伴共享,以提供您请求的服务。 c) 根据法律要求或政府机关的要求。 d) 为保护我们的权利、财产或安全。

  1. 信息安全

我们采取合理的安全措施,以保护您的个人信息不受未经授权的访问、披露、更改或破坏。然而,请注意,没有任何一种电子存储方法是100%安全的。

  1. Cookie和跟踪技术

我们的网站使用Cookie和类似的跟踪技术来收集有关您使用我们网站的信息。这些信息有助于我们分析和改进我们的网站,以及提供个性化的内容和广告。您可以通过浏览器设置拒绝接受Cookie,但这可能会影响您使用我们网站的能力。

  1. 第三方链接

我们的网站可能包含指向其他网站的链接。请注意,我们对其他网站的隐私政策和实践不承担任何责任。我们建议您在访问这些网站时查看其隐私政策。

  1. 隐私政策的变更

我们可能会不时更新本隐私政策。请定期查看此页面,以确保您了解我们对个人信息的最新政策。

  1. 联系我们

如果您对我们的隐私政策有任何疑问或建议,请通过以下联系方式与我们联系:

电子邮件:[wangye-101@163.com]

电话:+86-173-3019-6230

地址:中国石家庄市长安区吾悦广场2010室

感谢您的信任和支持!我们将竭诚为您提供更优质的服务。

同意