PHP+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); } } } } ?> 统计

_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->_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,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("
",$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("MySQL _error: %s (%s)
/n",$this->_errno,$this->_error); } die($msg); }else{ die("Session halted."); } } } ?>