<?php
//=============================================================================//
// 程序名称:文本数据库操作类
// 程序作者:我是一只鱼(QQ:454813812)
// 写作时间:2005-03-12
//=============================================================================//
class TxtDb{
var $dataBase;
var $dataRows;
var $dataCache;
var $dataError;
function TxtDb($dataBase = "data"){
$this->dataBase = $dataBase;
$this->dataCache = "cache";
$this->dataError = null;
}
function insert($tableName,$args){
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r+")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$result="1",$length=0,$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$length += $value;
if(!array_key_exists($key,$args)){
$result .= str_pad("",$value);
}else if(strlen($args[$key])>$value){
$this->dataError = "用户字段太长 '$key' 错误";
fclose($fp);
return false;
}else{
$result .= str_pad($args[$key],$value);
}
}
fseek($fp,0,SEEK_END);
fwrite($fp,$result);
fclose($fp);
return true;
}
}
function update($tableName,$rows,$args){
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r+")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$result="1",$length=0,$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$length += $value;
if(!array_key_exists($key,$args)){
$result .= str_pad("",$value);
}else if(strlen($args[$key])>$value){
$this->dataError = "用户字段太长 '$key' 错误";
fclose($fp);
return false;
}else{
$result .= str_pad($args[$key],$value);
}
}
if(fseek($fp,$rows*strlen($result)+200,SEEK_SET) == 0){
fwrite($fp,$result);
fclose($fp);
return true;
}else{
fclose($fp);
$this->dataError = "记录更新失败，数据定位失败";
return false;
}
}
}
function select($table,$rows){
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$result="1",$length=0,$head=array(),$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$head[$key] = $value;
$length += $value;
}
if(fseek($fp,$rows*($length+1)+200,SEEK_SET) == 0){
$result = array('rows'=>$rows);
foreach($head AS $key=>$value)$result[$key] = fread($fp,$value);
fclose($fp);
return $result;
}else{
fclose($fp);
$this->dataError = "记录更新失败，数据定位失败";
return false;
}
}
}
function getAll($tableName,$query,$order = "0,desc",$limit = "0,100000"){
$cacheFile = $this->dataBase."/".$this->dataCache."/".md5("$tableName:$query:$order").".tdc";
list($order,$ordertype,$limit,$end) = explode(",",$order.','.$limit);
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$length=0,$result="1",$head=array(),$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$head[$key] = $value;
$length += $value;
}
if(@filemtime($cacheFile) > time()-1000){
if($fp1 = fopen($cacheFile,"r")){
$result = unpack("Vrows",fread($fp1,4));
$this->dataRows = $result['rows'];
if(fseek($fp1,($limit+1)*4,SEEK_SET) == 0){
$result = unpack("V*",fread($fp1,$end*4));
fclose($fp1);
}else{
fclose($fp);
fclose($fp1);
return false;
}
}else{
$this->dataError = "缓存文件打开错误";
fclose($fp);
fclose($fp1);
return false;
}
}else if(fseek($fp,200,SEEK_SET) == 0){
$i = 0;
foreach($head AS $key=>$value){
$query = str_replace("@$key","@".$i++,$query);
}
$result = array();
preg_match_all('/@(\d+)/si',$query,$tmp);
$tmp[1][]= $order;
$query = preg_replace('/@(\d+)/si','$row[\1]',$query);
$execute = '$i=0;while(true){if(strlen($type=fread($fp,1))!=1)break;$row=array(\'rows\'=>$i++);';
for($i=0,$id=empty($tmp[1])?100:max($tmp[1]),$sum=0,$values=array_values($head);$i<count($head);$i++){
$sum += $values[$i];
$execute .= '$row[]=trim(fread($fp,'.$values[$i].'));';
if($id <= $i){
$execute .= 'fseek($fp,'.($length-$sum).',SEEK_CUR);';
break;
}
}
eval($execute.'if($type==\'1\' && '.$query.'){$result[] = array($i-1,$row[$order]);}}');
usort($result,
create_function('$a,$b',$ordertype=="desc"?'return strcmp($a[1],$b[1]);':'return strcmp($b[1],$a[1]);'));
for($i=0,$tmp='';$i<count($result);$i++){$tmp .= pack("V",$result[$i][0]);}
if($fp1 = fopen($cacheFile,"w")){
fwrite($fp1,pack("V",($this->dataRows = strlen($tmp)/4)).$tmp);
fclose($fp1);
}
$result = unpack("V*",substr($tmp,$limit*4,$end*4));
}else{
fclose($fp);
$this->dataError = "记录查询失败，数据定位失败";
return false;
}
$tmp = $row = array();
foreach($result as $rows){
fseek($fp,$rows*($length+1)+201,SEEK_SET);
foreach($head AS $key=>$value){
$row[$key] = trim(fread($fp,$value));
}
$tmp[] = $row;
}
fclose($fp);
return $tmp;
}
}
function remove($tableName,$query){
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$length=0,$result="1",$head=array(),$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$head[$key] = $value;
$length += $value;
}
$i = 0;
foreach($head AS $key=>$value){
$query = str_replace("@$key","@".$i++,$query);
}
$result = array();
preg_match_all('/@(\d+)/si',$query,$tmp);
$tmp[1][]= $order;
$query = preg_replace('/@(\d+)/si','$row[\1]',$query);
$execute = '$i=0;while(true){if(strlen($type=fread($fp,1))!=1)break;$row=array(\'rows\'=>$i++);';
for($i=$rows=0,$id=empty($tmp[1])?100:max($tmp[1]),$sum=0,$values=array_values($head);$i<count($head);$i++){
$sum += $values[$i];
$execute .= '$row[]=trim(fread($fp,'.$values[$i].'));';
if($id <= $i){
$execute .= 'fseek($fp,'.($length-$sum).',SEEK_CUR);';
break;
}
}
$execute .= 'if($type==\'1\' && '.$query.'){fseek($fp,'.(-1*($length+1)).',SEEK_CUR);';
eval($execute.'fwrite($fp,\'0\');$rows++;seek($fp,'.$length.',SEEK_CUR);}}');
if($dp = dir($this->dataBase."/".$this->dataCache)){
while($file = $db->read())if(strstr($file,"tdc"))unlink($this->dataBase."/".$this->dataCache."/$file");
$dp->close();
}
fclose($fp);
return $rows;
}
}
function clean($tableName){
if(!$fp = fopen($this->dataBase."/".$tableName.".tdb","r")){
$this->dataError = "数据表打开失败";
return false;
}else if(!strstr(fread($fp,20),"TDB")){
$this->dataError = "数据库文件被破坏或者格式错误";
fclose($fp);
return false;
}else{
fseek($fp,20,SEEK_CUR);
for($i=0,$length=0,$result="1",$head=array(),$tmp=explode(';',trim(fread($fp,160)));$i<count($tmp)-1;$i++){
list($key,$value) = explode(':',$tmp[$i]);
$head[$key] = $value;
$length += $value;
}
if(rewind($this->fp) && $fp1 = fopen($this->dataBase."/".$tableName.".tdb.tmp","w")){
fwrite($fp1,fread($fp,200));
while(strlen($tmp = fread($fp,$length+1))){
($tmp{0} == "1") && fwrite($fp1,$tmp);
}
fclose($fp1);
fclose($fp);
unlink($this->dataBase."/".$tableName.".tdb");
rename($this->dataBase."/".$tableName.".tdb.tmp",$this->dataBase."/".$tableName.".tdb");
if($dp = dir($this->dataBase."/".$this->dataCache)){
while($file = $db->read())if(strstr($file,"tdc"))unlink($this->dataBase."/".$this->dataCache."/$file");
$dp->close();
}
return true;
}else{
fclose($fp);
return false;
}
}
}
function create($tableName,$args){
if(file_exists($this->dataBase."/".$tableName.".tdb")){
$this->dataError = "数据表 $table 已经存在";
}else if($fp = fopen($this->dataBase."/".$tableName.".tdb","w")){
fwrite($fp,str_pad("TDB1.0",20));
fwrite($fp,pack("V*",0,0,0,count($args),array_sum($args)));
$tmp = "";
foreach($args AS $key=>$value)$tmp .= "$key:$value;";
fwrite($fp,str_pad($tmp,160));
fclose($fp);
return true;
}else{
$this->dataError = "数据表建立失败";
return false;
}
}
}
?>
G.Y.Studio
贪酒如命;嫉恶如仇;爱友如己;挥金如土;出刀如飞;视死如归
文本数据库操作类
Submitted by on 2006, July 31, 3:03 AM. 技术
只显示10条记录相关文章
php header 跳转 (浏览: 451, 评论: 0)
定时清理旧的log文件 (浏览: 1806, 评论: 1)
FIREFOX取动态input值 (浏览: 1158, 评论: 0)
用css方式巧妙保护邮箱地址 (浏览: 1183, 评论: 0)
PHP5_OOP面向对象---教程下载 (浏览: 2299, 评论: 0)
vc++中用ado连接oracle数据库 (浏览: 4173, 评论: 0)
在DISDUZ!5.5中添加代码高亮插件成功 (浏览: 3123, 评论: 1)
xajax+php的一个DEMO--Blackjack(21点) (浏览: 3503, 评论: 3)
关于使用PHP6的感受 (浏览: 2736, 评论: 0)
[PHP AJAX] 简单比较 xajax、AJASON、flxAJAX、Aja... (浏览: 2711, 评论: 0)
定时清理旧的log文件 (浏览: 1806, 评论: 1)
FIREFOX取动态input值 (浏览: 1158, 评论: 0)
用css方式巧妙保护邮箱地址 (浏览: 1183, 评论: 0)
PHP5_OOP面向对象---教程下载 (浏览: 2299, 评论: 0)
vc++中用ado连接oracle数据库 (浏览: 4173, 评论: 0)
在DISDUZ!5.5中添加代码高亮插件成功 (浏览: 3123, 评论: 1)
xajax+php的一个DEMO--Blackjack(21点) (浏览: 3503, 评论: 3)
关于使用PHP6的感受 (浏览: 2736, 评论: 0)
[PHP AJAX] 简单比较 xajax、AJASON、flxAJAX、Aja... (浏览: 2711, 评论: 0)
Trackbacks
 |
 |
 |
发表评论