函数|数据|数据库
/**
* 文件数据库函数
* 约定：
* 数据库名为同名目录
* 数据表名后缀为 tab
* 索引文件后缀为 ind
* 管理文件名为 数据库同名目录/manage.ini
* 备注型字段以独立文件存在，表中保留文件名
* 字段以定长方式或csv方式保存，由管理文件指定
* 每行一条记录
* 索引文件以二进制方式包存键值(定长)和偏移量(长整型)
*
** 函数列表(前面有：+ 为已实现，- 为部分实现，其余为尚未实现)
套用 mysql 函数集 取名 file_db
* file_affected_rows: 得到 file_db 最后操作影响的列数目。
*-file_close: 关闭 file_db 服务器连接。
* file_connect: 打开 file_db 服务器连接。
*+file_create_db: 建立一个 file_db 新数据库。
* file_data_seek: 移动内部返回指针。
* file_db_query: 送查询字符串 (query) 到 file_db 数据库。
* file_drop_db: 移除数据库。
* file_errno: 返回错误信息代码。
* file_error: 返回错误信息。
*+file_fetch_array: 返回数组资料。
* file_fetch_field: 取得字段信息。
* file_fetch_lengths: 返回单列各栏资料最大长度。
* file_fetch_object: 返回类资料。
*+file_fetch_row: 返回单列的各字段。
*+file_field_name: 返回指定字段的名称。
* file_field_seek: 配置指针到返回值的某字段。
* file_field_table: 获得目前字段的资料表 (table) 名称。
* file_field_type: 获得目前字段的类型。
* file_field_flags: 获得目前字段的标志。
* file_field_len: 获得目前字段的长度。
* file_free_result: 释放返回占用内存。
* file_insert_id: 返回最后一次使用 insert 指令的 id。
* file_list_fields: 列出指定资料表的字段 (field)。
* file_list_dbs: 列出 file_db 服务器可用的数据库 (database)。
* file_list_tables: 列出指定数据库的资料表 (table)。
*+file_num_fields: 取得返回字段的数目。
*+file_num_rows: 取得返回列的数目。
* file_pconnect: 打开 file_db 服务器持续连接。
*-file_query: 送出一个 query 字符串。
* file_result: 取得查询 (query) 的结果。
* file_select_db: 选择一个数据库。
* file_tablename: 取得资料表名称。
*/
/**
*
*
$cmp_key;
/** 连结至 file_db 资料库
* @param 数据库名
*/
function &file_connect($dbname) {
$filename = $dbname./manage.ini;
if(!file_exists($filename))
die(数据库:$dbnamee不存在);
$fp = fopen($filename,r);
$s = fgets($fp,filesize($filename)+1);
fclose($fp);
$db = unserialize($s);
return $db;
}
/** 关闭 file_db 连结
*
*/
function file_close(&$connection_id) {
unset($connection_id);
}
/** 建立 file_db 数据库
* @param 数据库名
*/
function file_create_db($dbname) {
if(! @mkdir($dbname,0700))
$err = 目录已存在;
$filename = $dbname./manage.ini;
$ar[path] = $dbname/;
$s = serialize($ar);
$fp = fopen($filename,w);
fputs($fp,$s);
fclose($fp);
}
/** 执行 sql 指令
*
*/
function file_query($query,&$connection_id,$_line = __line__) {
// 解析 $query
$query = eregi_replace([ ]+, ,$query);
$ar = split( ,trim(str_replace( , ,$query)));
$query = eregi_replace(\r?\n,,$query);
$ch = each($ar);
switch(strtoupper($ch[1])) {
case create:
if(! eregi(create table (.+) [(] *(.+)[)] *$,$query,$pp))
die(sql表达式错,$_line);
$table = $pp[1];
if(empty($connection_id[$table])) {
// 解析字段表达式
$ar = split(,,$pp[2]);
while(list($key,$value) = each($ar)) {
$str = split( ,trim($value));
eregi(([a-z0-9]+) ([a-z]+) ?([(]([0-9]+)[)])?(.+)?,$value,$pp);
$field[name] = $pp[1];
$field[type] = $pp[2];
$field[len] = $pp[4];
$field[style] = trim($pp[5]);
$sss[] = $field;
}
$connection_id[$table] = array(
fields => $sss,
filename => $table..tab,
type => csv
);
}
$fp = fopen($connection_id[path].manage.ini,w);
fputs($fp,serialize($connection_id));
fclose($fp);
break;
case select:
if(! eregi(select (.+) from ([^ ]+) *(.+)*$,$query,$pp))
die(sql表达式错,$_line);
// 解析sql语句的控制部分
$exte = $pp[3];
if(! eregi(where ,$exte))
$exte = where true .$exte;
if(! eregi(order ,$exte))
$exte .= order by 0;
if(! eregi(group ,$exte))
$exte = eregi_replace(order ,group by _ order ,$exte);
eregi(where (.+) *group by (.+) order by (.+),$exte,$regs);
$filter = trim($regs[1]);
$group = trim($regs[2]);
$order = trim($regs[3]);
if($group == _) $group = ;
if($order == 0) $order = ;
// 读取数据文件
if(empty($connection_id[$pp[2]]))
die(表.$pp[2].不存在);
$table = $connection_id[$pp[2]];
if(!file_exists($connection_id[path].$table[filename])) {
// 数据表尚未建立
return false;
}else {
// 获取表定义字段名
for($i=0;$i $defaultfield[] = $table[fields][$i][name];
$defaultfield = array_flip($defaultfield);
// 解析筛选表达式
if($filter != true) {
$filter = eregi_replace( and , && ,$filter);
$filter = eregi_replace( or , || ,$filter);
$filter = eregi_replace(=,==,$filter);
$filter = eregi_replace(==>,=>,$filter);
$filter = eregi_replace( $filter = eregi_replace(===,==,$filter);
while (ereg ('([a-z][a-z0-9_]*)', $filter, $regs)) {
$found = $regs[1];
$filter = eregi_replace($found,[. $defaultfield][$found].], $filter);
}
$filter = eregi_replace(\[,\$tmp][,$filter);
$filter = \$key=($filter);;
}else
$filter =;
// 装入数据
$fp = fopen($connection_id][path].$table[filename],r);
$key = true;
while($tmp = fgetcsv($fp,4096,`)) {
if(!empty($filter)) eval($filter);
if($key)
$temp[] = $tmp;
}
fclose($fp);
}
// 解析输出字段
$f = split(,,$pp[1]);
$expr = ;
while(list($key,$value) = each($f)) {
if(eregi((.+)[(](.+)[)]( as (.+))?,$value,$pp)) {
// 有函数
switch(strtoupper($pp[1])) {
case count:
if(empty($pp[4]))
$n = cnt;
else
$n = $pp[4];
$expr .= \$rs[$n]=1;;
$sumname[] = $n;
break;
}
}else if(eregi((.+) as (.+),$value,$pp)) {
// 有重命名
$n = $defaultfield[$pp[1]];
if(!isset($n)) die(字段名 $n 非法);
$expr .= \$rs[$pp[2]]=\$temp[\$i][$n];;
}else if($value == *) {
for($i=0;$i $value = $table[fields][$i][name];
$expr .= \$rs[$value]=\$temp[\$i][$i];;
}
}else {
$n = $defaultfield[$value];
if(!isset($n)) die(sql error);
$expr .= \$rs[$value]=\$temp[\$i][$n];;
}
}
// 取得输出字段列表
$i=0;
eval($expr);
$outfield = array_keys($rs);
// 解析分组
if($group) {
$groups = split(,,$group);
for($i=0;$i if(eregi([0-9]+,$groups[$i])) {
$n = $groups[$i]>0?$groups[$i]-1:0;
$groups[$i] = $outfield[$n];
}
}
// 过录数据
for($i=0;$i eval($expr);
if(!$group)
$result[] = $rs;
else {
$n = $rs[$groups[0]];
if($sumname) {
for($ii=0;$ii $sumdata[$sumname][$ii]] = $result[$n][$sumname][$ii]];
$result[$n] = $rs;
for($ii=0;$ii $result[$n][$sumname][$ii]] += $sumdata[$sumname][$ii]];
}else
$result[$n] = $rs;
}
}
unset($temp);
// 解析排序
if($order) {
global $cmp_key;
$orders = split(,,$order);
for($i=count($orders)-1;$i>=0;$i--) {
eregi(([0-9]+)?([a-z_][a-z0-9_]*)? *(desc)?,$orders[$i],$regs);
if(!empty($regs[1])) {
$n = $regs[1]-1;
if($n $cmp_key = $outfield[$n];
}else
$cmp_key = $regs[2];
if(empty($regs[3]))
usort($result, cmp_asc);
else
usort($result, cmp_desc);
}
}
return $result;
break;
case insert:
if(! eregi(insert into table (.+) [(](.+)[)] *values? *[(](.+)[)],$query,$pp))
die(sql表达式错,$_line);
if(empty($connection_id[$pp[1]]))
die(表.$pp[1].不存在);
$table = $connection_id[$pp[1]];
// 解析目标字段名
$f = split(,,$pp[2]);
// 检查字段是否合法
for($i=0;$i if(!array_scan($table[fields],$f[$i],name))
die(字段名非法 .$f[$i]);
// 根据表字段表构造数据数组
for($i=0;$i $data[$table][fields][$i][name]] = ;
// 解析数据
eval(\$d=array($pp[3]););
// 填表
for($i=0;$i $data[$f[$i]] = $d[$i];
}
$fp = fopen($connection_id[path].$table[filename],a);
fputs($fp,join(`,$data).\n);
fclose($fp);
break;
case update:
break;
default:
die(错误的sql指令,在.$_line.行);
}
}
/** file_fetch_row: 返回单列的各字段
*
*/
function file_fetch_row(&$result) {
$ar = each($result);
if(! $ar) return false;
while(list($k,$ch) = each($ar[1]))
$br[] = $ch;
return $br;
}
/** file_fetch_array: 返回数组资料
*
*/
function file_fetch_array(&$result) {
$ar = each($result);
if(! $ar) return false;
while(list($k,$ch) = each($ar[1])) {
$br[] = $ch;
$br[$k] = $ch;
}
return $br;
}
/** file_field_name: 返回指定字段的名称
*
*/
function file_field_name(&$result,$n=0) {
$outfield = array_keys($result[0]);
return $outfield[$n];
}
/** file_num_rows: 取得返回列的数目
*
*/
function file_num_rows(&$result) {
return count($result);
}
/** file_num_fields: 取得返回字段的数目
*
*/
function file_num_fields(&$result) {
return count($result[0]);
}
/** 工作函数集
*/
/** 在数组中检索
* @param $ar 数组
* @param $val 待检索的值
* @param $key 键
*/
function array_scan($ar,$val,$key=0) {
for($i=0;$i if($ar[$i][$key] == $val)
return true;
return false;
}
/** 排序用工作函数(降序 由usort()调用)
*/
function cmp_desc($a,$b) {
global $cmp_key;
if ($a[$cmp_key] == $b[$cmp_key]) return 0;
return ($a[$cmp_key] > $b[$cmp_key]) ? -1 : 1;
}
/** 排序用工作函数(升序 由usort()调用)
*/
function cmp_asc($a,$b) {
global $cmp_key;
if ($a[$cmp_key] == $b[$cmp_key]) return 0;
return ($a[$cmp_key] > $b[$cmp_key]) ? 1 : -1;
}
// 应用实例
file_create_db(test);
$conn = file_connect(test);
$s = create table board (
sn int primary key auto_increment,
name varchar(15) not null,
email varchar(30),
ip varchar(15),
time datetime,
content tinyblob not null);
file_query($s,$conn);
//file_query(insert into table board (sn,name,ip) value (15,'w,r,r,oi','$remote_addr'),$conn);
//$rs = file_query(select * from board,$conn);
$rs = file_query(select * from board where true group by 2 order by 2 desc,$conn);
//$rs = file_query(select count(*) as js,time as hj,ip as pi,name,sn from board group by name order by sn desc,$conn);
//$rs = file_query(select sn,name,email,io from board where true group by 1 order by 2 desc,$conn);
file_close($conn);
echo
;
echo ;
for($i=0;$i echo .file_field_name($rs,$i).;
echo
;
for($j=0;$j echo ;
$d = file_fetch_row($rs);
for($i=0;$i echo .$d[$i]. ;
echo
;
}
echo
;
?>