PHP数据操作种

Jun 13, 2016 pm 01:11 PM
gt link return table this

PHP数据操作类

<?php

/**

+----------------------

 * Mysql操作类

+----------------------

 * 文件名称  Db.class.php

+----------------------

 * 文件描述  mysql操作类

+----------------------

 */

class Db{

    //数据库连接标识

    protected $link = null;

    //当前操作的表

    public $table = '';

    //查询参数

    protected $options = array();

    //当前执行的SQL语句

    protected $sql = '';

    //用什么编码传递数据

    protected $dbCharset = 'utf8';



    //缓存路径

    protected $cachePath = './cache/';

    //缓存扩展名

    protected $cacheFileExt = "php";

    //缓存文件名

    protected $cacheFileName;

    //是否缓存

    protected $cache = false;

    //缓存更新时间秒数

    protected $cacheLimitTime = 60;



    //数据返回类型, 1代表数组, 2代表对象

    protected $returnType = 1;



  /*

   * 根据当前动态文件生成缓存文件名

   */

	function setCacheFileName($fileName) {

		$cacheFileName = $this->cachePath . strtoupper(md5($fileName)).".".$this->cacheFileExt;

		$this->cacheFileName=$cacheFileName;

    }

  /*

   * 根据当前动态文件生成缓存文件名

   */

	function getCacheFileName() {

		return  $this->cacheFileName;

    }

    /**

     * 连接数据库

     *

     * @access      public

     * @param       array    $db  数据库配置

     * @return      resource 数据库连接标识

     */

    public function connect($db){

        //根据配置使用不同函数连接数据库

        $db['host'] = isset($db['port']) ? $db['host'].':'.$db['port']: $db['host'];

        $db['char'] = isset($db['char']) ? $db['char']: $this->dbCharset;

        $func = $db['pconnect'] ? 'mysql_pconnect' : 'mysql_connect';

        $this->link = $func($db['host'], $db['user'], $db['pwd']);

        mysql_select_db($db['database'], $this->link);

        mysql_query("SET NAMES '{$db['char']}'");

        $this->cachePath = isset($db['cachepath']) ? $db['cachepath']: $this->cachePath;

        return $this->link;

    }

    /**

     * 查询符合条件的一条记录

     *

     * @access      public

     * @param       string    $where  查询条件

     * @param       string    $field  查询字段

     * @param       string    $table  表

     * @return      mixed             符合条件的记录

     */

    public function find($where = NULL, $field = '*', $table = ''){

        return $this->findAll($where = NULL, $field = '*', $table = '', FALSE);

    }

    /**

     * 查询符合条件的所有记录

     *

     * @access      public

     * @param       string    $where  查询条件

     * @param       string    $field  查询字段

     * @param       string    $table  表

     * @return      mixed             符合条件的记录

     */

    public function findAll($where = NULL, $field = '*', $table = '', $all = TRUE){

        $this->options['where'] = is_null($where) ? @$this->options['where']: $where;

        $this->options['field'] = isset($this->options['field']) ? $this->options['field']: $field;

        $this->options['table'] = $table == '' ? $this->table: $table;

        $sql = "SELECT {$this->options['field']} FROM `{$this->options['table']}` ";

        $sql .= isset($this->options['join']) ? ' LEFT JOIN '.$this->options['join']: '';

        $sql .= isset($this->options['where']) ? ' WHERE '.$this->options['where']: '';

        $sql .= isset($this->options['group']) ? ' GROUP BY '.$this->options['group']: '';

        $sql .= isset($this->options['having']) ? ' HAVING '.$this->options['having']: '';

        $sql .= isset($this->options['order']) ? ' ORDER BY '.$this->options['order']: '';

        $sql .= isset($this->options['limit']) ? ' LIMIT '.$this->options['limit']: '';

        $this->sql = $sql;

        $row = NULL;

        //如果开启了缓存, 那么重缓存中获取数据

        if ($this->cache === TRUE){

			$this->setCacheFileName($this->sql);

            $row = $this->readCache();

        }

        //如果读取失败, 或则没有开启缓存

        if (is_null($row)){

            $result = $this->query();

            $row = $all === TRUE ? $this->fetchAll($result): $this->fetch($result);

            //如果开启了缓存, 那么就写入

            if ($this->cache === TRUE){

                $this->writeCache($row);

            }

            $this->options = array();

        }

        return $row;

    }

    /**

     * 读取结果集中的所有记录到数组中

     *

     * @access public

     * @param  resource  $result  结果集

     * @return array

     */

    public function fetchAll($result = NULL){

        $rows = array();

        while ($row = $this->fetch($result)){

            $rows[] = $row;

        }

        return $rows;

    }

    /**

     * 读取结果集中的一行记录到数组中

     *

     * @access public

     * @param  resource  $result  结果集

     * @param  int       $type    返回类型, 1为数组, 2为对象

     * @return mixed              根据返回类型返回

     */

    public function fetch($result = NULL, $type = NULL){

        $result = is_null($result) ? $this->result: $result;

        $type = is_null($type) ? $this->returnType: $type;

        $func = $type === 1 ? 'mysql_fetch_assoc' : 'mysql_fetch_object';

        return $func($result);

    }

    /**

     * 执行SQL命令

     *

     * @access      public

     * @param       string    $sql    SQL命令

     * @param       resource  $link   数据库连接标识

     * @return      mixed             数据库结果集

     */

    public function query($sql = '', $link = NULL){

        $sql = empty($sql) ? $this->sql: $sql;

        $link = is_null($link) ? $this->link: $link;

        $this->result = mysql_query($sql, $link);

        if (is_resource($this->result)){

            return $this->result;

        }

        //如果执行SQL出现错误, 那么抛出异常

        exit('<strong>Mysql error:</strong>'.$this->getError());

    }

    /**

     * 执行SQL命令

     *

     * @access      public

     * @param       string    $sql    SQL命令

     * @param       resource  $link   数据库连接标识

     * @return      bool              是否执行成功

     */

    public function execute($sql = '', $link = NULL){

        $sql = empty($sql) ? $this->sql: $sql;

        $link = is_null($link) ? $this->link: $link;

        if (mysql_query($sql, $link)){

            return TRUE;

        }

        return FALSE;

    }

    /**

     * 插入记录

     *

     * @access public

     * @param  array  $data  插入的记录, 格式:array('字段名'=>'值', '字段名'=>'值');

     * @param  string $table 表名

     * @return bool          当前记录id

     */

    public function add($data, $table = NULL){

        $table = is_null($table) ? $this->table: $table;

        $sql = "INSERT INTO `{$table}`";

        $fields = $values = array();

        $field = $value = '';

        //遍历记录, 格式化字段名称与值

        foreach($data as $key => $val){

            $fields[] = "`{$table}`.`{$key}`";

            $values[] = is_numeric($val) ? $val : "'{$val}'";

        }

        $field = join(',', $fields);

        $value = join(',', $values);

        unset($fields, $values);

        $sql .= "({$field}) VALUES({$value})";

        $this->sql = $sql;

        $this->execute();

        return $this->insertId();

    }

    /**

     * 删除记录

     *

     * @access public

     * @param  string  $where  条件

     * @param  string  $table  表名

     * @return bool            影响行数

     */

    public function delete($where = NULL, $table = NULL){

        $table = is_null($table) ? $this->table: $table;

        $where = is_null($where) ? @$this->options['where']: $where;

        $sql = "DELETE FROM `{$table}` WHERE {$where}";

        $this->sql = $sql;

        $this->execute();

        return $this->affectedRows();

    }

    /**

     * 更新记录

     *

     * @access public

     * @param  array   $data   更新的数据 格式:array('字段名' => 值);

     * @param  string  $where  更新条件

     * @param  string  $table  表名

     * @return bool            影响多少条信息

     */

    public function update($data, $where = NULL, $table = NULL){

        $table = is_null($table) ? $this->table: $table;

        $where = is_null($where) ? @$this->options['where']: $where;

        $sql = "UPDATE `{$table}` SET ";

        $values = array();

        foreach($data as $key => $val){

            $val = is_numeric($val) ? $val : "'{$val}'";

            $values[] = "`{$table}`.`{$key}` = {$val}";

        }

        $value = join(',', $values);

        $this->sql = $sql.$value." WHERE {$where}";

        $this->execute();

        return $this->affectedRows();

    }

    /**

     * 读取缓存

     *

     * @access      public

     * @return      mixed   如果读取成功返回缓存内容, 否则返回NULL

     */

    protected function readCache(){

        $file = $this->getCacheFileName();

        if (file_exists($file)){

            //缓存过期

            if ((filemtime($file) + $this->cacheLimitTime) < time()){

                @unlink($file);

                return NULL;

            }

            if (1 === $this->returnType){

                $row = include $file;

            }

            else{

                $data = file_get_contents($file);

                $row = unserialize($data);

            }

            return $row;

        }

        return NULL;

    }

    /**

     * 写入缓存

     *

     * @access      public

     * @param       mixed   $data   缓存内容

     * @return      bool            是否写入成功

     */

    public function writeCache($data){

        $file = $this->getCacheFileName();

        if ($this->makeDir(dirname($file))){

            if (1 === $this->returnType){

				$data = '<?php return '.var_export($data, TRUE).';?>';

			}else{

				$data = serialize($data);

			}

		}

        return file_put_contents($file, $data);

    }

	/*

	 * 清除缓存文件

	 * string $fileName 指定文件名(含函数)或者all(全部)

	 * 返回:清除成功返回true,反之返回false

	 */

	function clearCache( $fileName = "all" ) {

		if( $fileName != "all" ) {

			if( file_exists( $fileName ) ) {

				return @unlink( $fileName );

			}else return false;

		}

		if ( is_dir( $this->cachePath ) ) {

			if ( $dir = @opendir( $this->cachePath ) ) {

				while ( $file = @readdir( $dir ) ) {

					$check = is_dir( $file );

					if ( !$check )

					@unlink( $this->cachePath . $file );

				}

				@closedir( $dir );

				return true;

			}else{

				return false;

			}

		}else{

		  return false;

		}

	}

	  /*

	   * 连续建目录

	   * string $dir 目录字符串

	   * int $mode   权限数字

	   * 返回:顺利创建或者全部已建返回true,其它方式返回false

	   */

	function makeDir( $dir, $mode = "0777" ) {

		if( ! $dir ) return 0;

		$dir = str_replace( "\\", "/", $dir );

		

		$mdir = "";

		foreach( explode( "/", $dir ) as $val ) {

			$mdir .= $val."/";

			if( $val == ".." || $val == "." || trim( $val ) == "" ) continue;

		  

			if( ! file_exists( $mdir ) ) {

				if(!@mkdir( $mdir, $mode )){

					return false;

				}

			}

		}

		return true;

	}

	//自动加载函数, 实现特殊操作

    public function __call($func, $args)

    {

         if(in_array($func, array('field', 'join', 'where', 'order', 'group', 'limit', 'having')))

         {

               $this->options[$func] = array_shift($args);

               return $this;

         } elseif($func === 'table'){

               $this->options['table'] = array_shift($args);

               $this->table            = $this->options['table'];

               return $this;

         }

        //如果函数不存在, 则抛出异常

         exit('Call to undefined method Db::' . $func . '()');

     }

//-------------------------------------------

        //返回上一次操作所影响的行数

    public function affectedRows($link = null){

		$link = is_null($link) ? $this->link : $link;

		return mysql_affected_rows($link);

    }



        //返回上一次操作记录的id

    public function insertId($link = null){

        $link = is_null($link) ? $this->link : $link;

        return mysql_insert_id($link);

    }



        //清空结果集

    public function free($result = null){

         $result = is_null($result) ? $this->result : $result;

         return mysql_free_result($result);

    }



        //返回错误信息

	public function getError($link = NULL){

        $link = is_null($link) ? $this->link : $link;

        return mysql_error($link);

    }



        //返回错误编号

	public function getErrno($link = NULL){

        $link = is_null($link) ? $this->link : $link;

        return mysql_errno($link);

    }

}

?>
Copier après la connexion

?调用方法:

<?php

include ('DB.php');   //引入类文件

$db = new Db();    //实例化mysql操作类



//数据库配置信息数组

$config['host']     = 'localhost';   //mysql主机

$config['user']     = 'root';        //用户

$config['pwd']      = '';            //密码

$config['port']     = '3306';        //端口

$config['database'] = 'message';     //数据库

$config['char']     = 'utf8';        //字符集

$config['pconnect'] = FALSE;         //是否使用持久性连接



$link = $db->connect($config);  //传入配置, 连接数据库, $link为连接标识

$rows = $db->table('test')->field('*')->order('id DESC')->limit(0, 10)->findAll();

//上面的操作, 相当于执行SQL命令: SELECT * FROM test ORDER BY id DESC LIMIT 0, 10;



print_r($db->getCacheFileName());

//$db->clearCache($db->getCacheFileName());

//$db->clearCache();

// 执行的效果和上面相同, 但是多了一个cache方法,也就缓存了这次查询 cache()有三个参数, cache(缓存名称, 有效时间, 缓存路径); 缓存名称默认是使用md5(SQL命令)为名称, 有效时间默认为1分钟, 缓存路径可以在连接数据库时进行配置



//下面来插入一条记录

$data = array(

       'name'  => 'xiaokai',

       'pass'  => '123456',

);



$db->add($data);

// 这样就插入了一条记录 注意这里$data的格式为 array('字段名称1' => '值1', '字段名称2' => '值2', .....);

//相当于执行SQL命令: INSERT INTO test(`name`, `pass`) VALUES('xiaokai', '123456');

//朋友们可能奇怪了, add 函数并没有传入表名称啊, 为什么会执行这样的SQL命令呢?

//其实在上面查询的时候就已经使用$db->table('test')方法了, 这里已经传入了表名称, 所以在操作就不需要指定表名称了.



//有插入就有删除, 下面来删除

$db->delete('id = 10');

//这样就删除了test表中 id为10的记录

//相当于执行SQL命令: DELETE FROM test WHERE id = 10;

//这里也是一样没有传入表名称



//下面构造数组, 然后更新一条记录

$data = array(

       'name'  => '123456',

       'pass'  => 'xiaokai',

);

$db->update($data, 'id = 10');

//这样就将id为10的记录给更新了

//相当于执行SQL命令: UPDATE test set name = '123456', pass = 'xiaokai' WHERE id = 10; 
Copier après la connexion

?

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

Video Face Swap

Video Face Swap

Échangez les visages dans n'importe quelle vidéo sans effort grâce à notre outil d'échange de visage AI entièrement gratuit !

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Quelles sont les différences entre Huawei GT3 Pro et GT4 ? Quelles sont les différences entre Huawei GT3 Pro et GT4 ? Dec 29, 2023 pm 02:27 PM

De nombreux utilisateurs choisiront la marque Huawei lors du choix des montres intelligentes. Parmi eux, les Huawei GT3pro et GT4 sont des choix très populaires. De nombreux utilisateurs sont curieux de connaître la différence entre Huawei GT3pro et GT4. Quelles sont les différences entre Huawei GT3pro et GT4 ? 1. Apparence GT4 : 46 mm et 41 mm, le matériau est un miroir en verre + un corps en acier inoxydable + une coque arrière en fibre haute résolution. GT3pro : 46,6 mm et 42,9 mm, le matériau est du verre saphir + corps en titane/corps en céramique + coque arrière en céramique 2. GT4 sain : en utilisant le dernier algorithme Huawei Truseen5.5+, les résultats seront plus précis. GT3pro : ajout d'un électrocardiogramme ECG, d'un vaisseau sanguin et de la sécurité

Explication détaillée de l'utilisation de return en langage C Explication détaillée de l'utilisation de return en langage C Oct 07, 2023 am 10:58 AM

L'utilisation de return en langage C est la suivante : 1. Pour les fonctions dont le type de valeur de retour est void, vous pouvez utiliser l'instruction return pour terminer l'exécution de la fonction plus tôt. 2. Pour les fonctions dont le type de valeur de retour n'est pas void, la fonction de ; l'instruction return sert à terminer l'exécution de la fonction.Le résultat est renvoyé à l'appelant ;3. Terminer l'exécution de la fonction plus tôt que prévu.À l'intérieur de la fonction, nous pouvons utiliser l'instruction return pour terminer l'exécution de la fonction plus tôt. si la fonction ne renvoie pas de valeur.

Correctif : l'outil de capture ne fonctionne pas sous Windows 11 Correctif : l'outil de capture ne fonctionne pas sous Windows 11 Aug 24, 2023 am 09:48 AM

Pourquoi l'outil Snipping ne fonctionne pas sous Windows 11 Comprendre la cause première du problème peut aider à trouver la bonne solution. Voici les principales raisons pour lesquelles l'outil de capture peut ne pas fonctionner correctement : L'assistant de mise au point est activé : cela empêche l'ouverture de l'outil de capture. Application corrompue : si l'outil de capture plante au lancement, il est peut-être corrompu. Pilotes graphiques obsolètes : des pilotes incompatibles peuvent interférer avec l'outil de capture. Interférence provenant d'autres applications : d'autres applications en cours d'exécution peuvent entrer en conflit avec l'outil de capture. Le certificat a expiré : une erreur lors du processus de mise à niveau peut provoquer ce problème. Solution simple. Celles-ci conviennent à la plupart des utilisateurs et ne nécessitent aucune connaissance technique particulière. 1. Mettez à jour les applications Windows et Microsoft Store

Quel est l'ordre d'exécution des instructions return et enfin en Java ? Quel est l'ordre d'exécution des instructions return et enfin en Java ? Apr 25, 2023 pm 07:55 PM

Code source : publicclassReturnFinallyDemo{publicstaticvoidmain(String[]args){System.out.println(case1());}publicstaticintcase1(){intx;try{x=1;returnx;}finally{x=3;}}}# Sortie La sortie du code ci-dessus peut simplement conclure : return est exécuté avant finalement. Jetons un coup d'œil à ce qui se passe au niveau du bytecode. Ce qui suit intercepte une partie du bytecode de la méthode case1 et compare le code source pour annoter la signification de chaque instruction dans

Comment réparer l'erreur Impossible de se connecter à l'App Store sur iPhone Comment réparer l'erreur Impossible de se connecter à l'App Store sur iPhone Jul 29, 2023 am 08:22 AM

Partie 1 : étapes de dépannage initiales Vérification de l'état du système Apple : avant d'aborder des solutions complexes, commençons par les bases. Le problème ne vient peut-être pas de votre appareil ; les serveurs Apple sont peut-être en panne. Visitez la page État du système d'Apple pour voir si l'AppStore fonctionne correctement. S'il y a un problème, tout ce que vous pouvez faire est d'attendre qu'Apple le résolve. Vérifiez votre connexion Internet : assurez-vous que vous disposez d'une connexion Internet stable, car le problème "Impossible de se connecter à l'AppStore" peut parfois être attribué à une mauvaise connexion. Essayez de basculer entre le Wi-Fi et les données mobiles ou de réinitialiser les paramètres réseau (Général > Réinitialiser > Réinitialiser les paramètres réseau > Paramètres). Mettez à jour votre version iOS :

php提交表单通过后,弹出的对话框怎样在当前页弹出,该如何解决 php提交表单通过后,弹出的对话框怎样在当前页弹出,该如何解决 Jun 13, 2016 am 10:23 AM

php提交表单通过后,弹出的对话框怎样在当前页弹出php提交表单通过后,弹出的对话框怎样在当前页弹出而不是在空白页弹出?想实现这样的效果:而不是空白页弹出:------解决方案--------------------如果你的验证用PHP在后端,那么就用Ajax;仅供参考:HTML code

Comment Vue3 utilise-t-il le sucre syntaxique de configuration pour refuser d'écrire le retour Comment Vue3 utilise-t-il le sucre syntaxique de configuration pour refuser d'écrire le retour May 12, 2023 pm 06:34 PM

Le sucre de syntaxe de configuration de Vue3.2 est un sucre de syntaxe au moment de la compilation qui utilise l'API combinée dans un composant de fichier unique (SFC) pour résoudre la configuration lourde de Vue3.0. Les variables, fonctions et contenus déclarés introduits par l'importation sont exposés via. return, afin qu'ils puissent être utilisés dans Vue3.0. Problèmes d'utilisation 1. Il n'est pas nécessaire de renvoyer les variables, fonctions et contenus déclarés introduits par import lors de l'utilisation. Vous pouvez utiliser du sucre syntaxique //importer le contenu introduit import{getToday. }from'./utils'//variable constmsg='Bonjour !'//function func

Voyons pourquoi Vue2 peut accéder aux attributs dans diverses options via ceci Voyons pourquoi Vue2 peut accéder aux attributs dans diverses options via ceci Dec 08, 2022 pm 08:22 PM

Cet article vous aidera à interpréter le code source de Vue et à vous expliquer pourquoi vous pouvez l'utiliser pour accéder aux propriétés de diverses options de Vue2. J'espère qu'il sera utile à tout le monde !

See all articles