本篇文章主要介绍PHP+redis数据库操作的方法,感兴趣的朋友参考下,希望对大家有所帮助。
本文实例讲述了PHP+redis实现添加处理投票的方法。分享给大家供大家参考,具体如下:
<?php header("Content-Type:text/html;charset=utf-8"); include 'lib/mysql.class.php'; $mysql_obj = mysql::getConn(); if(class_exists('Redis')){ //redis $redis = new Redis(); $redis->pconnect('127.0.0.1', 6379); if(isset($_SERVER['HTTP_REFERER'])){ $url_md5 = md5($_SERVER['HTTP_REFERER']); } $adve_key = 'adve'; $adve_key_exists = 'adve_exists'; if(!$redis->exists($adve_key_exists)){ $list = $mysql_obj->fetch_array("select * from admin_online_adve"); if($list){ foreach ($list as $key => $value) { $url_hash = md5($value['adve_url']); $adve_hash_key = $adve_key.":".$url_hash; $id = $value['id']; $redis->set($adve_hash_key,$id); $redis->set($adve_key_exists,true); } } } $adve_new_key = $adve_key.':'.$url_md5; if($redis->exists($adve_new_key)){ $adve_plus = $adve_new_key.":plus" ; if(!$redis->exists($adve_plus)){ $redis->set($adve_plus,1); }else{ $redis->incr($adve_plus); $num = $redis->get($adve_plus); if($num >100){ $id = $redis->get($adve_new_key); // insert to sql; $mysql_obj->query("update admin_online_adve set adve_num=adve_num+$num where id=$id"); $redis->set($adve_plus,1); } } } } ?> <html> <head> <meta http-equiv="refresh" content="1;url=https://itunes.apple.com/cn/app/san-guo-zhi15-ba-wangno-da-lu/id694974270?mt=8"> <title>统计</title> </head> <body> <img src="loading.gif">Loading... </body> </html>
其中php连接mysql类mysql.class.php如下:
<?php define("MYSQL_SQL_GETDATA", 1); define("MYSQL_SQL_EXECUTE", 2); class mysql_db{ var $_server; //数据库服务器地址 var $_user; //数据库连接帐号 var $_password; //数据库连接密码 var $_dbname; //数据库名称 var $_persistency=false; //是否使用持久连接 var $_isConnect = false; //是否已经建立数据库连接 var $_charset="utf8"; //数据库连接字符集 var $_isDebug = false; //是否Debug模式 var $_sql=array(); //执行sql语句数组 var $_db_connect_id; //数据库连接对象标识 var $_result; //执行查询返回的值 var $_record; var $_rowset; var $_errno = 0; var $_error = "connection error"; var $_checkDB = false; function mysql_db($dbserver, $dbuser, $dbpassword,$database,$persistency = false,$autoConnect=false,$checkdb = false) { $this->_server = $dbserver; $this->_user = $dbuser; $this->_password = $dbpassword; $this->_dbname = $database; $this->_persistency = $persistency; $this->_autoConnect = $autoConnect; $this->_checkDB = $checkdb; if($autoConnect){ $this->connection(); } } function connection($newLink = false) { if (!$newLink){ if($this->_isConnect && isset($this->_db_connect_id)){ @mysql_close($this->_db_connect_id); } } $this->_db_connect_id = ($this->persistency) ? @mysql_pconnect($this->_server, $this->_user, $this->_password):@mysql_connect($this->_server, $this->_user, $this->_password,$newLink); if ($this->_db_connect_id) { if ($this->version() > '4.1') { if ($this->_charset != "") { @mysql_query("SET NAMES '".str_replace('-', '', $this->_charset)."'", $this->_db_connect_id); } } if ($this->version() > '5.0') { @mysql_query("SET sql_mode=''", $this->_db_connect_id); } //检测指定数据库是否连接成功 if ($this->_checkDB){ $dbname = mysql_query('SELECT database()',$this->_db_connect_id); $dbname = mysql_fetch_array($dbname,MYSQL_NUM); $dbname = trim($dbname[0]); }else{ $dbname = ''; } if ($dbname==$this->_dbname || $dbname==''){ if (!@mysql_select_db($this->_dbname, $this->_db_connect_id)) { @mysql_close($this->_db_connect_id); $this->_halt("cannot use database " . $this->_dbname); } }else{ if ($this->_checkDB && !$newLink){ $this->connection(true); } } return true; } else { $this->_halt('connect failed.',false); } } function setCharset($charset){ //$charset = str_replace('-', '', $charset); $this->_charset = $charset; } function setDebug($isDebug=true){ $this->_isDebug = $isDebug; } function query($sql,$type='') { return $this->_runSQL($sql,MYSQL_SQL_GETDATA,$type); } function execute($sql) { return $this->_runSQL($sql,MYSQL_SQL_EXECUTE,"UNBUFFERED"); } function _runSQL($sql,$sqlType=MYSQL_SQL_GETDATA,$type = '') { if ($type =="UNBUFFERED"){ $this->_result = @mysql_unbuffered_query($sql,$this->_db_connect_id); }else{ $this->_result = @mysql_query($sql,$this->_db_connect_id); } //测试模式下保存执行的sql语句 if($this->_isDebug){ $this->_sql[]=$sql; } if ($this->_result) { return $sqlType==MYSQL_SQL_GETDATA?$this->getNumRows():$this->getAffectedRows(); }else{ $this->_halt("Invalid SQL: ".$sql); return false; } } function next($result_type=MYSQL_ASSOC) { $this->fetchRow($result_type); return is_array($this->_record); } function f($name) { if(is_array($this->_record)){ return $this->_record[$name]; }else{ return false; } } function fetchRow($result_type=MYSQL_ASSOC) { if( $this->_result ) { $this->_record = @mysql_fetch_array($this->_result,$result_type); return $this->_record; }else{ return false; } } function getAll($sql,$primaryKey="",$result_type=MYSQL_ASSOC) { if ($this->_runSQL($sql,MYSQL_SQL_GETDATA)>=0){ return $this->fetchAll($primaryKey,$result_type); }else{ return false; } } function getOne($sql,$result_type=MYSQL_ASSOC) { if ($this->_runSQL($sql,MYSQL_SQL_GETDATA)>0){ $arr = $this->fetchAll("",$result_type); if(is_array($arr)){ return $arr[0]; } }else{ return false; } } function fetchAll($primaryKey = "",$result_type=MYSQL_ASSOC) { if ($this->_result) { $i = 0; $this->_rowset = array(); if ($primaryKey=="") { while($this->next($result_type)) { $this->_rowset[$i] = $this->_record; $i++; } }else{ while($this->next($result_type)) { $this->_rowset[$this->f($primaryKey)] = $this->_record; $i++; } } return $this->_rowset; }else{ //$this->_halt("Invalid Result"); return false; } } function checkExist($sql) { return $this->query($sql)>0?true:false; } function getValue($sql, $colset = 0) { if ($this->query($sql)>0){ $this->next(MYSQL_BOTH); return $this->f($colset); }else{ return false; } } function getNumRows() { return @mysql_num_rows($this->_result); } function getNumFields() { return @mysql_num_fields($this->_result); } function getFiledName($offset) { return @mysql_field_name($this->_result, $offset); } function getFiledType($offset) { return @mysql_field_type($this->_result, $offset); } function getFiledLen($offset) { return @mysql_field_len($this->_result, $offset); } function getInsertId() { return @mysql_insert_id($this->_db_connect_id); } function getAffectedRows() { return @mysql_affected_rows($this->_db_connect_id); } function free_result() { $ret = @mysql_free_result($this->_result); $this->_result = 0; return $ret; } function version() { return @mysql_get_server_info($this->_db_connect_id); } function close() { return @mysql_close($this->_db_connect_id); } function sqlOutput($isOut = true, $all = true){ if($all){ $ret = implode("<br>",$this->_sql); }else{ $ret = $this->_sql[count($this->_sql)-1]; } if ($isOut){ echo $ret; }else{ return $ret; } } function _halt($msg="Session halted.",$getErr=true) { if($this->_isDebug){ if($getErr){ $this->_errno = @mysql_errno($this->_db_connect_id); $this->_error = @mysql_error($this->_db_connect_id); printf("<b>MySQL _error</b>: %s (%s)<br></font>/n",$this->_errno,$this->_error); } die($msg); }else{ die("Session halted."); } } } ?>
总结:以上就是本篇文的全部内容,希望能对大家的学习有所帮助。
相关推荐:
以上是PHP+redis数据库操作的方法的详细内容。更多信息请关注PHP中文网其他相关文章!

PHP在现代Web开发中仍然重要,尤其在内容管理和电子商务平台。1)PHP拥有丰富的生态系统和强大框架支持,如Laravel和Symfony。2)性能优化可通过OPcache和Nginx实现。3)PHP8.0引入JIT编译器,提升性能。4)云原生应用通过Docker和Kubernetes部署,提高灵活性和可扩展性。

PHP适合web开发,特别是在快速开发和处理动态内容方面表现出色,但不擅长数据科学和企业级应用。与Python相比,PHP在web开发中更具优势,但在数据科学领域不如Python;与Java相比,PHP在企业级应用中表现较差,但在web开发中更灵活;与JavaScript相比,PHP在后端开发中更简洁,但在前端开发中不如JavaScript。

PHP和Python各有优势,适合不同场景。1.PHP适用于web开发,提供内置web服务器和丰富函数库。2.Python适合数据科学和机器学习,语法简洁且有强大标准库。选择时应根据项目需求决定。

PHP是一种广泛应用于服务器端的脚本语言,特别适合web开发。1.PHP可以嵌入HTML,处理HTTP请求和响应,支持多种数据库。2.PHP用于生成动态网页内容,处理表单数据,访问数据库等,具有强大的社区支持和开源资源。3.PHP是解释型语言,执行过程包括词法分析、语法分析、编译和执行。4.PHP可以与MySQL结合用于用户注册系统等高级应用。5.调试PHP时,可使用error_reporting()和var_dump()等函数。6.优化PHP代码可通过缓存机制、优化数据库查询和使用内置函数。7

PHP成为许多网站首选技术栈的原因包括其易用性、强大社区支持和广泛应用。1)易于学习和使用,适合初学者。2)拥有庞大的开发者社区,资源丰富。3)广泛应用于WordPress、Drupal等平台。4)与Web服务器紧密集成,简化开发部署。

PHP在现代编程中仍然是一个强大且广泛使用的工具,尤其在web开发领域。1)PHP易用且与数据库集成无缝,是许多开发者的首选。2)它支持动态内容生成和面向对象编程,适合快速创建和维护网站。3)PHP的性能可以通过缓存和优化数据库查询来提升,其广泛的社区和丰富生态系统使其在当今技术栈中仍具重要地位。

在PHP中,弱引用是通过WeakReference类实现的,不会阻止垃圾回收器回收对象。弱引用适用于缓存系统和事件监听器等场景,需注意其不能保证对象存活,且垃圾回收可能延迟。

\_\_invoke方法允许对象像函数一样被调用。1.定义\_\_invoke方法使对象可被调用。2.使用$obj(...)语法时,PHP会执行\_\_invoke方法。3.适用于日志记录和计算器等场景,提高代码灵活性和可读性。


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

MinGW - 适用于 Windows 的极简 GNU
这个项目正在迁移到osdn.net/projects/mingw的过程中,你可以继续在那里关注我们。MinGW:GNU编译器集合(GCC)的本地Windows移植版本,可自由分发的导入库和用于构建本地Windows应用程序的头文件;包括对MSVC运行时的扩展,以支持C99功能。MinGW的所有软件都可以在64位Windows平台上运行。

DVWA
Damn Vulnerable Web App (DVWA) 是一个PHP/MySQL的Web应用程序,非常容易受到攻击。它的主要目标是成为安全专业人员在合法环境中测试自己的技能和工具的辅助工具,帮助Web开发人员更好地理解保护Web应用程序的过程,并帮助教师/学生在课堂环境中教授/学习Web应用程序安全。DVWA的目标是通过简单直接的界面练习一些最常见的Web漏洞,难度各不相同。请注意,该软件中

EditPlus 中文破解版
体积小,语法高亮,不支持代码提示功能

SublimeText3 Linux新版
SublimeText3 Linux最新版

SublimeText3汉化版
中文版,非常好用