php投票系统简单实现源码(1/3)

本文章详细的介绍了关于投票系统实现原理与实现代码，有需要的朋友可参考一下。

数据库的设计
设计三张表：投票结果统计表（count_voting），投票人记录表（ip_votes），用户表（user）

投票结果统计表用于统计最后的投票记录，我给它弄了4个字段：被投票项的名称（SelectName），被投票项标签名（LabelName）（起到分类的作用），票数（CountVotes）。

投票人记录表用于登记投票人的ip（IP），地理位置（Location），投票时间（VoteTime），被投票项名称（SelectName）。然后我还给它加一个ID。

用户表主要用于给管理员用的，包含用户名（name）和密码（passwd）。

生成表的sql脚本如下：

代码如下

复制代码

-- -- 表的结构 `count_voting` -- DROP TABLE IF EXISTS `count_voting`; CREATE TABLE IF NOT EXISTS `count_voting` (   `SelectName` varchar(40) NOT NULL,   `LabelName` varchar(40) NOT NULL,   `CountVotes` bigint(20) unsigned NOT NULL,   UNIQUE KEY `SelectName` (`SelectName`),   KEY `CountVotes` (`CountVotes`),   KEY `CountVotes_2` (`CountVotes`),   KEY `CountVotes_3` (`CountVotes`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='投票统计表'; -- -------------------------------------------------------- -- -- 表的结构 `ip_votes` -- DROP TABLE IF EXISTS `ip_votes`; CREATE TABLE IF NOT EXISTS `ip_votes` (   `ID` bigint(20) unsigned NOT NULL auto_increment COMMENT '投票人序号：自增',   `IP` varchar(15) NOT NULL COMMENT '投票人IP',   `Location` varchar(40) NOT NULL COMMENT '投票人位置',   `VoteTime` datetime NOT NULL,   `SelectName` varchar(40) NOT NULL,   PRIMARY KEY  (`ID`),   KEY `ID` (`ID`),   KEY `SelectName` (`SelectName`) ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=4 ; -- -- 触发器 `ip_votes` -- DROP TRIGGER IF EXISTS `vote_count_after_insert_tr`; DELIMITER // CREATE TRIGGER `vote_count_after_insert_tr` AFTER INSERT ON `ip_votes`  FOR EACH ROW UPDATE count_voting SET CountVotes = CountVotes + 1 WHERE SelectName = NEW.SelectName // DELIMITER ; -- -------------------------------------------------------- -- -- 表的结构 `user` -- DROP TABLE IF EXISTS `user`; CREATE TABLE IF NOT EXISTS `user` (   `name` varchar(10) NOT NULL COMMENT '管理员用户名',   `passwd` char(32) NOT NULL COMMENT '登录密码MD5值' ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户表'; -- -- 转存表中的数据 `user` -- INSERT INTO `user` (`name`, `passwd`) VALUES ('ttxi', '700469ca1555900b18c641bf7b0a1fa1'), ('jitttanwa', 'adac5659956d68bcbc6f40aa5cd00d5c'); -- -- 限制导出的表 -- -- -- 限制表 `ip_votes` -- ALTER TABLE `ip_votes`   ADD CONSTRAINT `ip_votes_ibfk_1` FOREIGN KEY (`SelectName`) REFERENCES `count_voting` (`SelectName`) ON DELETE CASCADE ON UPDATE CASCADE;

从脚本中可以看出，我创建了一个触发器，当往ip_votes表中插入数据的时候就给count_voting表中的CountVotes字段加1。还能后出最后一句是设置外部关联字。

框架设计
OperatorDB类用于操作数据库，OperatorVotingDB类用于该系统特定的操作集合。
使用PDO操作数据库，我它简单的封装一下：

代码如下

复制代码

/**  * 操作数据库  * 封装PDO，使其方便自己的操作  */ class OperatorDB {     //连接数据库的基本信息     private $dbms='mysql';       //数据库类型,对于开发者来说，使用不同的数据库，只要改这个.     private $host='localhost';       //数据库主机名     private $dbName='voting';     //使用的数据库     private $user='voting';       //数据库连接用户名     private $passwd='voting';     //对应的密码     private $pdo=null;     public function  __construct()     {         //dl("php_pdo.dll");         //dl("php_pdo_mysql.dll");         $this->dsn="$this->dbms:host=$this->host;dbname=$this->dbName";         try         {             $this->conn=new PDO($this->dsn,$this->user,$this->passwd);//初始化一个PDO对象，就是创建了数据库连接对象$db         }         catch(PDOException $e)         {             die(" 数据库连接失败(creater PDO Error！): ".$e->getMessage()." ");         }     }     public function __destruct()     {         $this->pdo = null;     }     public function exec($sql)     {     }     public function query($sql)     {     } }

把连接数据库的信息封装进去方便后续的操作。

代码如下

复制代码

require_once 'OperatorDB.php'; class OperatorVotingDB {     private $odb;     public function  __construct()     {         $this->odb = new OperatorDB();     }     public function __destruct()     {         $this->odb = null;     }     /**      * 清空Voting数据中的所有表      *      * 调用数据库操作类，执行clear数据库的操作      */     public function clearTables()     {         $sqls = array("TRUNCATE ip_votes;","TRUNCATE count_voting;");         $this->odb->exec($sqls[0]);         $this->odb->exec($sqls[1]);     }     /**      * 重置count_voting表中的CountValues字段为0      *      */     public function resetCountValues()     {         $sql = "UPDATE count_voting SET CountVotes = 0;";         $this->odb->exec($sql);     }     /**      * 投票      * 将信息写入ip_votes表      * @param type $ip      * @param type $loc      * @param type $time      * @param type $name      */     public function vote($ip,$loc,$name)     {         $sql = "INSERT INTO ip_votes VALUES (NULL, '$ip', '$loc', NOW(), '$name')";         $subsql = "SELECT MAX(to_days(VoteTime)) FROM ip_votes WHERE IP='$ip'";         $stm = $this->odb->query($subsql);         if (count($row=$stm->fetchAll())==1)         {             $now = date("Y-m-d H:i:s");             $subsql = "SELECT to_days('$now');";             $stm = $this->odb->query($subsql)->fetch();             $time = $stm[0];//使用mysql计算出的today时间 //            echo $time." "; //            echo $row[0][0];             if ($time-$row[0][0]            {                 echo "投票失败，相同ip需要隔一天才能投票";                 return;             }         } //        echo $sql;         echo "投票成功!";         $this->odb->exec($sql);     }     /**      * 添加SelectName字段的行      *      * @param string $name      * @param string $label      * @param int $count      */     public function addSelectName($name, $label, $count=0)     {         $sql = "INSERT INTO count_voting VALUES ('$name', '$label', $count);";         $this->odb->exec($sql);     }     /**      * 获取总投票情况,按票数排序的结果      *      * 按CountVotes字段排序，返回count_voting表      *      * @param int $n      *      */     public function getVotesSortByCount($n=-1)     {         $sql = "SELECT * FROM count_voting ORDER BY CountVotes DESC LIMIT 0 , $n;";         if (-1 == $n)         {             $sql = "SELECT * FROM count_voting ORDER BY CountVotes DESC;";         } //        echo $sql;         return $this->odb->query($sql);     }     /**      * 获取投票情况,按票数排序并按标签分组的结果      *      * 按CountVotes字段排序并按LabelName字段分组，返回count_voting表      */     public function getVotesGroupByLabel()     {         $sql = "SELECT * FROM count_voting ORDER BY LabelName DESC;"; //        echo $sql;         return $this->odb->query($sql);     } } ?>

1 2 3