php教程 php手册 一组文件数据库函数

一组文件数据库函数

Jun 21, 2016 am 09:12 AM
file filter nbsp quot table

函数|数据|数据库


/**
* 文件数据库函数
* 约定:
* 数据库名为同名目录
* 数据表名后缀为 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 "";
echo "";
for($j=0;$j  echo "";
  $d = file_fetch_row($rs);
  for($i=0;$i    echo "";
  echo "";
}
echo "
".file_field_name($rs,$i)."
".$d[$i]."
";
?>



본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

뜨거운 기사 태그

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

해결 방법: 조직에서 PIN 변경을 요구합니다. 해결 방법: 조직에서 PIN 변경을 요구합니다. Oct 04, 2023 pm 05:45 PM

해결 방법: 조직에서 PIN 변경을 요구합니다.

Windows 11에서 창 테두리 설정을 조정하는 방법: 색상 및 크기 변경 Windows 11에서 창 테두리 설정을 조정하는 방법: 색상 및 크기 변경 Sep 22, 2023 am 11:37 AM

Windows 11에서 창 테두리 설정을 조정하는 방법: 색상 및 크기 변경

Windows 11에서 제목 표시줄 색상을 변경하는 방법은 무엇입니까? Windows 11에서 제목 표시줄 색상을 변경하는 방법은 무엇입니까? Sep 14, 2023 pm 03:33 PM

Windows 11에서 제목 표시줄 색상을 변경하는 방법은 무엇입니까?

Windows 11에서 작업 표시줄 축소판 미리 보기를 활성화 또는 비활성화하는 방법 Windows 11에서 작업 표시줄 축소판 미리 보기를 활성화 또는 비활성화하는 방법 Sep 15, 2023 pm 03:57 PM

Windows 11에서 작업 표시줄 축소판 미리 보기를 활성화 또는 비활성화하는 방법

Windows 11/10 복구의 OOBELANGUAGE 오류 문제 Windows 11/10 복구의 OOBELANGUAGE 오류 문제 Jul 16, 2023 pm 03:29 PM

Windows 11/10 복구의 OOBELANGUAGE 오류 문제

Windows 11의 디스플레이 크기 조정 가이드 Windows 11의 디스플레이 크기 조정 가이드 Sep 19, 2023 pm 06:45 PM

Windows 11의 디스플레이 크기 조정 가이드

Windows 11에서 밝기를 조정하는 10가지 방법 Windows 11에서 밝기를 조정하는 10가지 방법 Dec 18, 2023 pm 02:21 PM

Windows 11에서 밝기를 조정하는 10가지 방법

Safari에서 iPhone의 개인 브라우징 인증을 끄는 방법은 무엇입니까? Safari에서 iPhone의 개인 브라우징 인증을 끄는 방법은 무엇입니까? Nov 29, 2023 pm 11:21 PM

Safari에서 iPhone의 개인 브라우징 인증을 끄는 방법은 무엇입니까?

See all articles