天馬行空-程式館

無窮遞迴，展 tree結構

2011 年 10 月 01 日 2 則迴響

主要的演算法如下 :

1) 建立一個暫存 Table。

2) 建立一個暫存 Array。

3) 採佇列先進先出的資料結構做法 ,依序將Array的元素 ,當查詢子階的傳入參數 ,逐一清空 ,並做遞迴演算。

程式如下 :


<?php
/**
* 程式名稱 : class.tree.php
* 程式功能 : 依會員帳號 ,展開tree結構。
* 備註           :
**/

class tree{

//建構方法
function __construct(){

//取得資料庫連線
$this->db = new mysqli('localhost','root','123456','My_test');

//判斷`tree_user`(暫存 Table是否存在)
$this->db->query("DROP TABLE IF EXISTS `tree_user`");
$this->db->query("CREATE TABLE IF NOT EXISTS `tree_user` (
`id` int(11) NOT NULL auto_increment COMMENT 'ID',
`account` varchar(20) NOT NULL,
`prev_id` int(11) NOT NULL default '0',
`acl` int(11) NOT NULL,
PRIMARY KEY  (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=1 ;");

//紀錄遞迴的所有資料陣列
$this->reg = array();
}

//遞迴方法
function Recursive($account){

if(!isset($account)){ //判斷是否有會員帳號
echo "<script>alert('無此帳號!');location.href='#'</script>";
exit;
}

//傳入會員帳號
$qry = $this->db->query("SELECT `id`,`account`,`prev_id`,`acl` FROM `member` WHERE `account`='".$account."' LIMIT 1");
$rlt = $qry->fetch_array();

if(isset($rlt['id'])){ //如果有該帳號 ,則 RUN 子階
$qry2 = $this->db->query("SELECT `id`,`account`,`prev_id`,`acl` FROM `member` WHERE `prev_id`='".$rlt['id']."'");
while($rlt2 = $qry2->fetch_array()){
//將資料寫入陣列  ,格式:'帳號,上一層,階層'
array_push($this->reg,$rlt2['account'].','.$rlt2['prev_id'].','.$rlt2['acl']);
}
}

if(count($this->reg)> 0){ //判斷 reg 陣列是否 >0

//將 $reg 轉成陣列
foreach ($this->reg as $val ){

$first = array_shift($this->reg); //移除第一個陣列元素
$first = (string)$first; //轉型字串

$val = explode(',',$first);

if(!empty($first)){
$this->db->query("INSERT INTO `tree_user`(`account`,`prev_id`,`acl`)VALUES('".(string)$val[0]."','".(string)$val[1]."','".(string)$val[2]."')");

$this->Recursive((string)$val[0]); //呼叫遞迴
   }
  }
 }
}
}

/* 結束 tree 程序*/

(後記 : 如果將程序寫成stored procedure ,那樣會減少反覆傳遞參數資料的過程 ,增加效能 ,改天有時間 ,再來挑戰看看 ^^)

歸檔於 PHP, 小技巧

用消息队列和消息应用状态表来消除分布式事务

2011 年 09 月 06 日發表迴響

(本文摘錄自 : http://rdc.taobao.com/blog/cs/?p=671)

由于数据量的巨大，大部分Web应用都需要部署很多个数据库实例。这样，有些用户操作就可能需要去修改多个数据库实例中的数据。传统的解决方法是使用分布式事务保证数据的全局一致性，经典的方法是使用两阶段提交协议。

长期以来，分布式事务提供的优雅的全局ACID保证麻醉了应用开发者的心灵，很多人都不敢越雷池一步，想像没有分布式事务的世界会是怎样。如今就如 MySQL和PostgreSQL这类面向低端用户的开源数据库都支持分布式事务了，开发者更是沉醉其中，不去考虑分布式事务是否给系统带来了伤害。

事实上，有所得必有所失，分布式事务提供的ACID保证是以损害系统的可用性、性能与可伸缩性为代价的。只有在参与分布式事务的各个数据库实例都能够正常工作的前提下，分布式事务才能够顺利完成，只要有一个工作不正常，整个事务就不能完成。这样，系统的可用性就相当于参加分布式事务的各实例的可用性之积，实例越多，可用性下降越明显。从性能和可伸缩性角度看，首先是事务的总持续时间通常是各实例操作时间之和，因为一个事务中的各个操作通常是顺序执行的，这样事务的响应时间就会增加很多；其次是一般Web应用的事务都不大，单机操作时间也就几毫秒甚至不到1毫秒，一但涉及到分布式事务，提交时节点间的网络通信往返过程也为毫秒级别，对事务响应时间的影响也不可忽视。由于事务持续时间延长，事务对相关资源的锁定时间也相应增加，从而可能严重增加了并发冲突，影响到系统吞吐率和可伸缩性。

正是由于分布式事务有以上问题，eBay在设计上就不采用分布式事务，而是通过其它途径来解决数据一致性问题。其中使用的最重要的技术就是消息队列和消息应用状态表。

举个例子。假设系统中有以下两个表

 user(id, name, amt_sold, amt_bought)
 transaction(xid, seller_id, buyer_id, amount)

其中user表记录用户交易汇总信息，transaction表记录每个交易的详细信息。

这样，在进行一笔交易时，若使用事务，就需要对数据库进行以下操作：

 begin;
 INSERT INTO transaction VALUES(xid, $seller_id, $buyer_id, $amount);
 UPDATE user SET amt_sold = amt_sold + $amount WHERE id = $seller_id;
 UPDATE user SET amt_bought = amt_bought + $amount WHERE id = $buyer_id;
 commit;

即在transaction表中记录交易信息，然后更新卖家和买家的状态。

假设transaction表和user表存储在不同的节点上，那么上述事务就是一个分布式事务。要消除这一分布式事务，将它拆分成两个子事务，一个更新transaction表，一个更新user表是不行的，因为有可能transaction表更新成功后，更新user失败，系统将不能恢复到一致状态。

解决方案是使用消息队列。如下所示，先启动一个事务，更新transaction表后，并不直接去更新user表，而是将要对user表进行的更新插入到消息队列中。另外有一个异步任务轮询队列内容进行处理。

 begin;
 INSERT INTO transaction VALUES(xid, $seller_id, $buyer_id, $amount);
 put_to_queue “update user(“seller”, $seller_id, amount);
 put_to_queue “update user(“buyer”, $buyer_id, amount);
 commit;
 for each message in queue
 begin;
 dequeue message;
 if message.type = “seller” then
 UPDATE user SET amt_sold = amt_sold + message.amount WHERE id = message.user_id;
 else
 UPDATE user SET amt_bought = amt_bought + message.amount WHERE id = message.user_id;
 end
 commit;
 end

上述解决方案看似完美，实际上还没有解决分布式问题。为了使第一个事务不涉及分布式操作，消息队列必须与transaction表使用同一套存储资源，但为了使第二个事务是本地的，消息队列存储又必须与user表在一起。这两者是不可能同时满足的。

如果消息具有操作幂等性，也就是一个消息被应用多次与应用一次产生的效果是一样的话，上述问题是很好解决的，只要将消息队列放到 transaction表一起，然后在第二个事务中，先应用消息，再从消息队列中删除。由于消息队列存储与user表不在一起，应用消息后，可能还没来得及将应用过的消息从队列中删除时系统就出故障了。这时系统恢复后会重新应用一次这一消息，由于幂等性，应用多次也能产生正确的结果。

但实际情况下，消息很难具有幂等性，比如上述的UPDATE操作，执行一次和执行多次的结束显然是不一样的。解决这一问题的方法是使用另一个表记录已经被成功应用的消息，并且这个表使用与user表相同的存储。假设增加以下表 message_applied(msg_id)记录被成功应用的消息，则产生最终的解决方案如下：

 begin;
 INSERT INTO transaction VALUES(xid, $seller_id, $buyer_id, $amount);
 put_to_queue “update user(“seller”, $seller_id, amount);
 put_to_queue “update user(“buyer”, $buyer_id, amount);
 commit;
 for each message in queue
 begin;
 SELECT count(*) as cnt FROM message_applied WHERE msg_id = message.id;
 if cnt = 0 then
 if message.type = “seller” then
 UPDATE user SET amt_sold = amt_sold + message.amount WHERE id = message.user_id;
 else
 UPDATE user SET amt_bought = amt_bought + message.amount WHERE id = message.user_id;
 end
 INSERT INTO message_applied VALUES(message.id);
 end
 commit;

if 上述事务成功

 dequeue message
 DELETE FROM message_applied WHERE msg_id = message.id;
 end
 end

我们来仔细分析一下：
1、消息队列与transaction使用同一实例，因此第一个事务不涉及分布式操作；
2、message_applied与user表在同一个实例中，也能保证一致性；
3、第二个事务结束后，dequeue message之前系统可能出故障，出故障后系统会重新从消息队列中取出这一消息，但通过message_applied表可以检查出来这一消息已经被应用过，跳过这一消息实现正确的行为；
4、最后将已经成功应用，且已经从消息队列中删除的消息从message_applied表中删除，可以将message_applied表保证在很小的状态（不清除也是可以的，不影响系统正确性）。由于消息队列与message_applied在不同实例上，dequeue message之后，将对应message_applied记录删除之前可能出故障。一但这时出现故障，message_applied表中会留下一些垃圾内容，但不影响系统正确性，另外这些垃圾内容也是可以正确清理的。

虽然由于没有分布式事务的强一致性保证，使用上述方案在系统发生故障时，系统将短时间内处于不一致状态。但基于消息队列和消息应用状态表，最终可以将系统恢复到一致。使用消息队列方案，解除了两个数据库实例之间的紧密耦合，其性能和可伸缩性是分布式事务不可比拟的。

当然，使用分布式事务有助于简化应用开发，使用消息队列明显需要更多的工作量，两者各有优缺点。个人观点是，对于时间紧迫或者对性能要求不高的系统，应采用分布式事务加快开发效率，对于时间需求不是很紧，对性能要求很高的系统，应考虑使用消息队列方案。对于原使用分布式事务，且系统已趋于稳定，性能要求高的系统，则可以使用消息队列方案进行重构来优化性能。

注: 本文取材于eBay的工程师Dan Pritchet写的这篇文章，并转载至http://wangyuanzju.blog.163.com/blog/static/1302920086424341932。

歸檔於資料庫

計算執行時間

2011 年 09 月 03 日發表迴響

一個簡單實用的小程序 ,以microtime為主角 ,計算執行時間 :

<?php

//Create a variable for start time
$time_start = microtime(true);

// Place your PHP/HTML/JavaScript/CSS/Etc. Here
for($i=0;$i<10000;$i++){
echo 'My name is Dio'.'<br>';
}

//Create a variable for end time
$time_end = microtime(true);

//Subtract the two times to get seconds
$time = $time_end - $time_start;

echo 'Script took '.$time.' seconds to execute';

/* close proc */

歸檔於 PHP, 小技巧

用Trigger設計log紀錄表

2011 年 08 月 28 日 4 則迴響

用 Trigger 設計 log 紀錄表:

Step1 : 建立 `my_trigger`資料表。

CREATE TABLE IF NOT EXISTS `my_trigger` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '編號',
`name` varchar(10) CHARACTER SET big5 NOT NULL COMMENT '姓名',
`phone` int(10) NOT NULL COMMENT '電話',
`email` varchar(80) CHARACTER SET big5 NOT NULL COMMENT 'email',
PRIMARY KEY (`id`)
) ENGINE=InnoDB  DEFAULT CHARSET=latin1 AUTO_INCREMENT=5 ;

Step2: 新增兩筆資料。

INSERT INTO `my_trigger` (`id`, `name`, `phone`, `email`) VALUES
(3, 'Dio', 7685423, 'linlong3388@yahoo.com'),
(4, 'Su', 333, 'Mark@gmail.com');

Step3: 建立 `sys_log`資料表。


CREATE TABLE IF NOT EXISTS `sys_log` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`content` text CHARACTER SET big5,
`cdate` datetime NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 AUTO_INCREMENT=1 ;

Step4: 建立 Trigger。


drop TRIGGER IF EXISTS `test`.`my_trig`;

DELIMITER $$

CREATE TRIGGER `my_trig` BEFORE UPDATE ON `test`.`my_trigger`
FOR EACH ROW

BEGIN

DECLARE chg TINYINT(1) DEFAULT 0;

SET @str = '';

-- 如果name有異動
IF NEW.name != OLD.name THEN
SET @str = CONCAT('name:',@str,OLD.name,'=>',NEW.name,',');
SET chg = 1;
END IF;

-- 如果phone有異動
IF NEW.phone != OLD.phone THEN
SET @str = CONCAT(@str,'phone:',OLD.phone,'=>',NEW.phone,',');
SET chg = 1;
END IF;

-- 如果email有異動
IF NEW.email != OLD.email THEN
SET @str = CONCAT(@str,'email:',OLD.email,'=>',NEW.email,',');
SET chg = 1;
END IF;

-- 如果任意欄位有異動 ,則寫入log表
IF chg = 1 THEN
SET @str = TRIM(BOTH ',' FROM @str); -- 截掉前後特殊符號
INSERT INTO `test`.`sys_log` (`id`,`content`,`cdate`) VALUES(NULL,@str,NOW());
END IF;

END$$

DELIMITER ;

Step5: 完成。

歸檔於資料庫

用 Trigger 判斷欄位更新

2011 年 08 月 26 日發表迴響

（本文摘錄自 : http://forums.mysql.com/read.php?99,166563,166628#msg-166628）
判斷Table裡的所有欄位 ,只要一有異動 ,就寫入到另一 Table。

DELIMITER $$

DROP TRIGGER /*!50033 IF EXISTS */ `oldFields`$$

CREATE TRIGGER `oldFields` BEFORE UPDATE on `order_request_item`
FOR EACH ROW
BEGIN
	DECLARE mychanged INT DEFAULT 0;
	IF NEW.item_name != OLD.item_name OR NEW.cat_no != OLD.cat_no OR NEW.description != OLD.description
	   OR NEW.quantity != OLD.quantity OR NEW.unit_price != OLD.unit_price OR NEW.quotation_no != OLD.quotation_no
	   OR NEW.size != OLD.size OR NEW.comment != OLD.comment THEN
		SET mychanged = 1;
	END IF;
	IF mychanged = 1 THEN
		INSERT INTO notification_mail
		SET item_id = NEW.item_id,
		create_time = NOW(),
		mail_to = OLD.end_user,
		item_name = NEW.item_name,
		cat_no = NEW.cat_no,
		description = NEW.description,
		quantity = NEW.quantity,
		unit_price = NEW.unit_price,
		size = NEW.size,
		quotation_no = NEW.quotation_no,
		comment = NEW.comment;
	END IF;
END$$

DELIMITER ;

歸檔於資料庫

Apache Rewrite URL強制定向規則

2011 年 08 月 25 日 2 則迴響

Step1 : 在 httpd.conf 下 ,定義如下的規則 :


#
# 自行追加Rewrite功能模組
#
RewriteEngine ON

# 寫進log記錄檔 ,RewriteLogLevel 0 表示關閉
RewriteLog "C:/AppServ/Apache2.2/logs/rewrite.log"
RewriteLogLevel 0

# url規則1 : 強制將main.php ,轉向Apache.html
RewriteRule ^/cash/main.php$ /cash/Apache.html [R]
RewriteRule ^/cash/Apache.html$ /cash/main.php

# url規則2 : 覆寫fp檔案位置
RewriteRule ^/cash/Apache_(.*).html$ /cash/main.php?fp=$1 [L]

Step2 : 在 php 檔 ,撰寫如下的code :


$url = 'reg';
$var = base64_encode('id=123456');
header("location: http://localhost/cash/Apache_{$url}.jsp?{$var}");

Step3 : 完成後 ,URL瀏覽 :


http://localhost/cash/Apache_reg.jsp?aWQ9MTIzNDU2

歸檔於配置與更新

如何在Apache环境下配置Rewrite规则

2011 年 08 月 24 日發表迴響

(完整內容,參考: http://faq.comsenz.com/viewnews-12)

URL 静态化是一个利于搜索引擎的设置，通过 URL 静态化，达到原来是动态的 PHP 页面转换为静态化的 HTML 页面，当然，这里的静态化是一种假静态，目的只是提高搜索引擎的搜索量，Comsenz 旗下的产品 Discuz!、SupeSite/X-Space、ECShop、SupeV、UCHome 等都支持此功能。当然这个功能还需要服务器环境的支持，下面介绍一下如何在 Apache 服务器下配置 URL 静态化的 Rewrite 规则。

当然这里分两种情况，一种是独立主机用户，这部分用户拥有对主机的管理权限，因此配置起来比较方便一些。（注：这里就以 Discuz!6.1.0 的 Rewrite 规则为例，稍后在后面会列举出其他产品的 Rewrite 规则。

首先确定您使用的 Apache 版本，及是否加载了 mod_Rewrite 模块。

Apache 1.x 的用户请检查 conf/httpd.conf 中是否存在如下两段代码：

LoadModule Rewrite_module libexec/mod_Rewrite.so
AddModule mod_Rewrite.c

Apache 2.x 的用户请检查 conf/httpd.conf 中是否存在如下一段代码：


LoadModule Rewrite_module modules/mod_Rewrite.so

如果存在，那么在配置文件（通常就是 conf/httpd.conf）中加入如下代码。此时请务必注意，如果网站使用通过虚拟主机来定义，请务必加到虚拟主机配置，即 <VirtualHost> 中去，如果加在虚拟主机配置外部将可能无法使用，改好后将 Apache 重启。


<IfModule mod_Rewrite.c>
RewriteEngine On
RewriteRule ^(.*)/archiver/((fid|tid)-[\w\-]+\.html)$ $1/archiver/index.php?$2
RewriteRule ^(.*)/forum-([0-9]+)-([0-9]+)\.html$ $1/forumdisplay.php?fid=$2&page=$3
RewriteRule ^(.*)/thread-([0-9]+)-([0-9]+)-([0-9]+)\.html$ $1/viewthread.php?tid=$2&extra=page\%3D$4&page=$3
RewriteRule ^(.*)/space-(username|uid)-(.+)\.html$ $1/space.php?$2=$3
RewriteRule ^(.*)/tag-(.+)\.html$ $1/tag.php?name=$2
</IfModule>

(……略)

歸檔於配置與更新

← 較舊的文章

天馬行空-程式館

修改 MySQL 帳密

將資料欄位，做Array映射

無窮遞迴，展 tree結構

mysql文件太大导入出错的解决方法

用消息队列和消息应用状态表来消除分布式事务

計算執行時間

用Trigger設計log紀錄表

用 Trigger 判斷欄位更新

Apache Rewrite URL強制定向規則

如何在Apache环境下配置Rewrite规则

文章分類

Dio

資源

登入

近期文章

Follow “天馬行空-程式館”