php 连接mssql 数据库配置与演示代码

function into_sql($file)
{
   global $mysql教程_host,$mysql_user,$mysql_password,$mysql_db,$mysql_table_prefix,$dbcharset;//获取数据库配置信息
    mysql_connect($mysql_host,$mysql_user,$mysql_password);
    mysql_select_db($mysql_db);

    if( mysql_get_server_info() < '4.1' )
    //返回 link_identifier 所使用的服务器版本。如果省略 link_identifier，则使用上一个打开的连接。
    {
        $dbcharset='';//设置字符集,如果mysql版本低于4.1,则不设置字符集信息
    }
 if(empty($dbcharset))
 {
  $dbcharset='gbk';
 }
    $dbcharset && mysql_query("set names '$dbcharset'");// 设置字符集
    if( mysql_get_server_info() > '5.0' )
    {
        mysql_query("set sql_mode=''");
    }
    $file2=file_get_contents($file);
 $file2=iconv("utf-8","gbk",$file2);
    $file2=str_replace("seo教程_",$mysql_table_prefix,$file2);//将文件中数据库表前缀换成用户设定的前缀
 
    $file2=explode("n",$file2);//将文件内容按行读入到数组
    $c1=count($file2);
    for($j=0;$j<$c1;$j++)
    {
        $ck=substr($file2[$j],0,4);//取每行的前4个字符
        if( ereg("#",$ck)||ereg("--",$ck) )//去掉注释
        {
            continue;
        }
        $arr[]=$file2[$j];//将去掉注释的文件内容按行读入数组$arr,数组每个元素对应一行
    }
    $read=implode("n",$arr); //重新组织文件内容到一个字符串,(按照原来分好的一行一行的)
    $sql=str_replace("r",'',$read);//去掉"r(回车符)"
    $detail=explode(";n",$sql);
    //将经上述整理过的文件内容再次按一条完整的sql语句(以;和n分隔)导入到数组$detail,
    //此时数组detail的每个元素对应一条完整的sql语句
    $count=count($detail);
    for($i=0;$i<$count;$i++)
    {
        $sql=str_replace("r",'',$detail[$i]);//去掉每行sql中的回车符
        $sql=str_replace("n",'',$sql);//去掉换行符
        $sql=trim($sql);//去掉前后空格
        //现在的$sql
        if($sql)
        {
            if(eregi("create table",$sql))//如果当前的sql语句是创建新表,则考虑版本兼容,以及重设字符集
            {
                //$mysqlv=mysql_get_server_info();
                $sql=preg_replace("/default charset=([a-z0-9]+)/is","",$sql);//去除原来的字符集设置信息
                $sql=preg_replace("/type=myisam/is","engine=myisam",$sql);
                if($dbcharset)
                {
                    $sql=str_replace("engine=myisam"," engine=myisam default charset=$dbcharset ",$sql);
                }
                if(mysql_get_server_info()<'4.1')
                {
                    $sql=preg_replace("/engine=myisam/is","type=myisam",$sql);//
                }
            }
            mysql_query($sql);
        }
    }
}

function write_file($sql,$filename) {
    $re=true;
    if(!@$fp=fopen("./www.111cn.net/".$filename,"w+")) {$re=false; echo "failed to open target file";}
    if(!@fwrite($fp,$sql)) {$re=false; echo "failed to write file";}
    if(!@fclose($fp)) {$re=false; echo "failed to close target file";}
    return $re;
}
function down_file($sql,$filename){
 ob_end_clean();
 header("content-encoding: none");
 header("content-type: ".(strpos($_server['http_user_agent'], 'msie') ? 'application/octetstream' : 'application/octet-stream'));

 header("content-disposition: ".(strpos($_server['http_user_agent'], 'msie') ? 'inline; ' : 'attachment; ')."filename=".$filename);

 header("content-length: ".strlen($sql));
 header("pragma: no-cache");

 header("expires: 0");
 echo $sql;
 $e=ob_get_contents();
 ob_end_clean();
}

function writeable($dir){
 if(!is_dir($dir)) {
     @mkdir($dir, 0777);
 }
 if(is_dir($dir)){
        if($fp = @fopen("$dir/test.test", 'w')){
            @fclose($fp);
            @unlink("$dir/test.test");
            $writeable = 1;
        }else {
            $writeable = 0;
     }
    }
 return $writeable;
}

function make_header($table){
    global $db;
    $sql="drop table if exists `".$table."`; ";
    $db->query("show create table ".$table);
    $db->nextrecord();
    $tmp=preg_replace("/ /","",$db->f("create table"));
    $sql.=$tmp."; ";
    return $sql;
}

function make_record($table,$num_fields){
    global $db;
    $comma="";
    $sql .= "insert into ".$table." values(";
    for($i = 0; $i < $num_fields; $i++)
    {$sql .= ($comma."'".mysql教程_escape_string($db->record[$i])."'"); $comma = ",";}
    $sql .= "); ";
    return $sql;
}

function show_msg($msgs){
    $i=0;
    $tm1="<table width='100%' border='0'  cellpadding='0' cellspacing='1'><tr><td><font color='red'><b>提示信息：</b></font></td></tr><tr><td><ul>";
    while (list($k,$v)=each($msgs)){
        $i=$i+1;
        $t1="<li>$i.".$v."</li>";
        $t=$t.$t1;
    }
    $tm2="</ul></td></tr></table>";
    return $tm1.$t.$tm2;
}

function pageend(){
    exit();
}

function import($fname) {
    global $db;
    $sqls=file($fname);
        foreach($sqls as $sql){
        str_replace(" ","",$sql);
        str_replace(" ","",$sql);
        if(!$db->query(trim($sql))) return false;
 }
    return true;
}
?>

class dbstuff {
 var $querynum = 0;
 var $link;
    var $sqlid;
    var $record;
    var $dbcharset='utf-8';
    var $charset='utf-8';
 function connect($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $halt = true) {
  if($pconnect) {
   if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
    $halt && $this->halt('can not connect to mysql server');
   }
  } else {
   if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw, 1)) {
    $halt && $this->halt('can not connect to mysql server');
   }
  }

  if($this->version() > '4.1') {
   global $charset, $dbcharset;
   if(!$dbcharset && in_array(strtolower($charset), array('gbk', 'big5', 'utf-8'))) {
    $dbcharset = str_replace('-', '', $charset);
   }

   if($dbcharset) {
    @mysql_query("set character_set_connection=$dbcharset, character_set_results=$dbcharset, character_set_client=binary", $this->link);
   }

   if($this->version() > '5.0.1') {
    @mysql_query("set sql_mode=''", $this->link);
   }
  }

  if($dbname) {
   @mysql_select_db($dbname, $this->link);
  }

 }

 function select_db($dbname) {
  return mysql_select_db($dbname, $this->link);
 }

 function fetch_array($query, $result_type = mysql_assoc) {
  return mysql_fetch_array($query, $result_type);
 }

 function query($sql, $type = '') {
  global $debug, $discuz_starttime, $sqldebug, $sqlspenttimes;

  $func = $type == 'unbuffered' && @function_exists('mysql_unbuffered_query') ?
   'mysql_unbuffered_query' : 'mysql_query';
  if(!($query = $func($sql, $this->link))) {
   if(in_array($this->errno(), array(2006, 2013)) && substr($type, 0, 5) != 'retry') {
    $this->close();
    $this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect);
    $this->query($sql, 'retry'.$type);
   } elseif($type != 'silent' && substr($type, 5) != 'silent') {
    $this->halt('mysql query error', $sql);
   }
  }

  $this->querynum++;
        $this->sqlid=$query;
  return $query;
 }

 function affected_rows() {
  return mysql_affected_rows($this->link);
 }

 function error() {
  return (($this->link) ? mysql_error($this->link) : mysql_error());
 }

 function errno() {
  return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
 }

 function result($query, $row) {
  $query = @mysql_result($query, $row);
  return $query;
 }

    function result_first($sql) {
  return $this->result($this->query($sql), 0);
 }

 function num_rows($query) {
  $query = mysql_num_rows($query);
  return $query;
 }

 function num_fields($query) {
  return mysql_num_fields($query);
 }

 function free_result($query) {
  return mysql_free_result($query);
 }

 function insert_id() {
  return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("select last_insert_id()"), 0);
 }

 function fetch_row($query) {
  $query = mysql_fetch_row($query);
  return $query;
 }

 function fetch_fields($query) {
  return mysql_fetch_field($query);
 }

 function version() {
  return mysql_get_server_info($this->link);
 }

 function close() {
  return mysql_close($this->link);
 }

    function nr($sql_id="") {
        if(!$sql_id) $sql_id=$this->sqlid;
     return mysql_num_rows($sql_id);
    }

    function nf($sql_id="") {
        if(!$sql_id) $sql_id=$this->sqlid;
        return mysql_num_fields($sql_id);
    }

    function nextrecord($sql_id="") {
        if(!$sql_id) $sql_id=$this->sqlid;
        if($this->record=mysql_fetch_array($sql_id))  return $this->record;
        else return false;
    }

    function f($name) {
        if($this->record[$name]) return $this->record[$name];
        else return false;
    }

    function lock($tblname,$op="write") {
        if(mysql_query("lock tables ".$tblname." ".$op)) return true;
        else return false;
    }

    function unlock()
        {if(mysql_query("unlock tables")) return true; else return false;}

    function ar() {
        return @mysql_affected_rows($this->link);
    }

    function i_id() {
            return mysql_insert_id();
    }

 function halt($message = '', $sql = '') {
  define('cache_forbidden', true);
  include('db_mysql_error.inc.php');
 }
}

?>

 */
class db_class {
 var $conn=null;
 var $querynum = 0;

 /**
  * 数据库连接，返回数据库连接标识符
  *
  * @param string $ 数据库服务器主机
  * @param string $ 数据库服务器帐号
  * @param string $ 数据库服务器密码
  * @param string $ 数据库名
  * @param bool $ 是否保持持续连接，1为持续连接，0为非持续连接
  * @return link_identifier $dbuser, $dbpw, $dbname,
  */
 function connect($dbhost, $pconnect = 0) {
  $error = '';
  $func = $pconnect == 1 ? 'sqlite_popen' : 'sqlite_open';
  if (!$this -> conn = $func($dbhost, 0666, $error)) {
   $this -> halt($error);
  }

  return $this -> conn;
 }

 /**
  * 执行sql语句
  *
  * @param string $ sql语句
  * @param string $ 默认为空，可选值为 cache unbuffered
  * @param int $ cache以秒为单位的生命周期
  * @return resource
  */
 function query($sql , $type = '' , $expires = 3600, $dbname = '') {
  $error = '';
  $func = $type == 'unbuffered' ? 'sqlite_unbuffered_query' : 'sqlite_query';
  if (preg_match("/^s*select/i", $sql)) {
   $query = $func($this -> conn, $sql, sqlite_assoc, $error);
  } else {
   $query = sqlite_exec($this -> conn, $sql, $error);
  }
  if ($error) {
   $this -> halt($error, $sql);
  }

  $this -> querynum++;
  return $query;
 }
 /*
 *@param string $ table名
 *@param string $ where条件
 *@param string $ colum名
 
 *@param string $ limit数量 
 
 */
 function getlist($table , $wheres = "1=1",  $colums = '*' ,$limits = '3000',$orderbys="id desc") {
  $query = $this -> query("select ".$colums." from ".$table." where ".$wheres." order by  ".$orderbys."  limit ".$limits, $type, $expires, $dbname);
  while($rs = $this -> fetch_array($query)){
   $datas[]=$rs;
   }
  //print_r("select ".$colums." from ".$table." where ".$wheres." limit ".$limits);
  //print_r($rs);die();
  $this -> free_result($query);
  return $datas ;
 }
 function add_one($table , $colums ,$data ) {
  //die("insert into ".$table." (".$colums.") values(".$data.")");
  $query = $this -> query("insert into ".$table." (".$colums.") values(".$data.")", $type, $expires, $dbname);
  //return $this->insert_id();
  return $query;
 }
 function delist($table , $idarray,$wheres="no") {
  if($wheres=='no')
   $query = $this -> query("delete from ".$table." where id in(".$idarray.")", $type, $expires, $dbname);
  else
   $query = $this -> query("delete from ".$table." where ".$wheres, $type, $expires, $dbname);
  return $query;
 }
 function updatelist($table , $updatedata,$idarray) {
  $query = $this -> query("update ".$table." set ". $updatedata."  where id in(".$idarray.")", $type, $expires, $dbname);
  return $query;
 }
 //update max_vote set maxtitle='$title',maxban='$ban',
 /**
  * 执行sql语句，只得到一条记录
  *
  * @param string $ sql语句
  * @param string $ 默认为空，可选值为 cache unbuffered
  * @param int $ cache以秒为单位的生命周期
  * @return array
  */
 function get_one($sql, $type = '', $expires = 3600, $dbname = '') {
  $query = $this -> query($sql, $type, $expires, $dbname);
  $rs = $this -> fetch_array($query);
  $this -> free_result($query);
  return $rs ;
 }

 /**
  * 从结果集中取得一行作为关联数组
  *
  * @param resource $ 数据库查询结果资源
  * @param string $ 定义返回类型
  * @return array
  */
 function fetch_array($query, $result_type = sqlite_assoc) {
  return sqlite_fetch_array($query, $result_type);
 }

 /**
  * 取得前一次 sqlite操作所影响的记录行数
  *
  * @return int
  */
 function affected_rows() {
  return sqlite_changes($this -> conn);
 }

 /**
  * 取得结果集中行的数目
  *
  * @return int
  */
 function num_rows($query) {
  return sqlite_num_rows($query);
 }

 /**
  * 返回结果集中字段的数目
  *
  * @return int
  */
 function num_fields($query) {
  return sqlite_num_fields($query);
 }

 /**
  *
  * @return array 备用,一般不用.
  */
 function result($query, $row) {
  return @sqlite_fetch_all($query, sqlite_assoc);
 }
 /**
  * sqlite没有相应函数
  */
 function free_result($query) {
  return ;
 }

 /**
  * 取得上一步 insert 操作产生的 id
  *
  * @return int
  */
 function insert_id() {
  return sqlite_last_insert_rowid($this -> connid);
 }

 /**
  *
  * @return array 只得到数字索引
  */
 function fetch_row($query) {
  return sqlite_fetch_array($query, sqlite_num);
 }
 /**
  */
 function fetch_assoc($query) {
  return $this -> fetch_array($query, sqlite_assoc);
 }
 /**
  *
  * @return string
  */
 function version() {
  return sqlite_libversion();
 }

 function close() {
  return sqlite_close($this -> conn);
 }

 /**
  *
  * @return string
  */
 function error() {
  return sqlite_error_string($this -> errno);
 }

 /**
  *
  * @return int
  */
 function errno() {
  return sqlite_last_error($this -> conn);
 }

 /**
  * 显示mysql教程错误信息
  */
 function halt($message = '', $sql = '') {
  exit("sqlitequery:$sql <br> sqliteerror:" . $this -> error() . " <br> sqliteerrno:" . $this -> errno() . " <br> message:$message");
 }
}

?>