/**

* PHP操作mssql數據庫類，含分頁類

* Enter description here ...

* @author aboc 9986584 2011-04-09

*

*/

class DB_Handle{

var $ClassName = "DB_Handle";

var $Server;

var $UserName;

var $Password;

var $Database;

var $LinkID=0;

var $QueryResult="";

var $LastInsertID = "";

//* private ignore=>ignore the error and continue, halt=>report the error and halt, report=>report the error and continue

var $Halt_On_Error = "report";

var $Error = "";

var $ErrNo = 0;

var $total = 0;

var $page = 0;

var $page_num = 10;

var $page_size = 10;

var $page_name = 'page';

//* remark: This is the db_mysql_class's structure * function: Set the server,username,password,database variable.

function DB_Handle($server="",$username="",$password="",$database=""){

$this->Server = $server;

$this->UserName = $username;

$this->Password = $password;

$this->Database = $database;

}

//* function: Connect database and select database * success: retun 1 * failed: return 0

function connect(){

$this->LinkID = @mssql_pconnect($this->Server,$this->UserName,$this->Password);

if(!$this->LinkID){

$this->halt("mssql_pconnect($this->Server,$this->UserName,$this->Password): Failed");

return 0;

}

if(!@mssql_select_db($this->Database)){

$this->halt("mssql_select_db($this->Database) Failed.");

return 0;

}

return 1;

}

//* function: Check the database, if exist then select * exist: return 1 * not exist: return 0

function selectDatabase(){

if(@mssql_select_db($this->Database))

return 1;

else

return 0;

}

//* function: Execute SQL instruction * success: return SQL Result. * failed: return 0;

function execQuery($sql=""){

if($this->LinkID == 0){

$this->halt("Execute SQL Failed: Hava not valid database connect.");

return 0;

}

ob_start();

$this->QueryResult = mssql_query($sql,$this->LinkID);

$error = ob_get_contents();

ob_end_clean();

if($error){

$this->halt("Execute SQL: mssql_query($sql,$this->LinkID) failed.");

return 0;

}

$reg = "#insert into#";

if(preg_match($reg,$sql)){

$sql = "select @@IDENTITY as id";

$res = mssql_query($sql,$this->LinkID);

$this->LastInsertID = mssql_result($res,0,id);

}

return $this->QueryResult;

}

//* function: Get the query result's row number//* success: return the row fo the Result//* failed: return 0

function getTotalRowNum($result=""){

if($result != "") $this->QueryResult = $result;

$row = @mssql_num_rows($this->QueryResult);

if($row >= 0) return $row;

$this->halt("Get a row of result Failed: Result $result is invalid.");

return 0;

}

//* function: Get the last insert record's id //* success: return id //* failed: return 0

function lastInsertID(){

return $this->LastInsertID;

}

//* function: Get a field's value * success: return value of the field * failed: return 0

function getField($result="",$row=0,$field=0){

if($result != "") $this->QueryResult = $result;

$fieldvalue = @mssql_result($this->QueryResult,$row,$field);

if($fieldvalue != "") return $fieldvalue;

$this->halt("Get field: mssql_result($this->QueryResult,$row,$field) failed.");

return 0;

//Here should have error handle

}

//* function: Get next record * success: return a array of the record's value * failed: return 0

function nextRecord($result=""){

if($result != "") $this->QueryResult = $result;

$record = @mssql_fetch_array($this->QueryResult);

if(is_array($record)){

foreach ($record as $key=>$row)

$record[$key] = trim($row);

return $record;

}

//$this->halt("Get the next record Failed: the Result $result is invalid.");

return 0;

}

//* function: Free the Query Result * success return 1 * failed: return 0

function freeResult($result=""){

if($result != "") $this->QueryResult = $result;

return @mssql_free_result($this->QueryResult);

}

//* function: Set the Halt_On_Error's state * success: return 1 * failed: return 0

function setHaltOnError($state="ignore"){

if(!($state == "ignore" || $state == "report" || $state == "halt")){

$this->halt("Set the Halt_On_Error Fail: There is no state value $state");

return 0;

}

$this->Halt_On_Error = $state;

return 1;

}

//* function: Get the Halt_On_Error's state

function getHaltOnError(){

return $this->Halt_On_Error;

}

//* function: Get the class's name

function toString(){

return $this->ClassName;

}

//* function: Error handle

function halt($msg){

$this->Error = @mysql_error($this->LinkID);

$this->ErrNo = @mysql_errno($this->LinkID);

if ($this->Halt_On_Error == "ignore") return;

$this->makeMsg($msg);

if ($this->Halt_On_Error == "halt") die("Session halted");

}

//* function: Make error information and print

function makeMsg($msg){

printf("Database error: %s

\n", $msg);

printf("MySQL Error: %s (%s)

\n",$this->ErrNo,$this->Error);

}

/**

* 以下為分頁類

*/

private function getQuery(){

$query = '';

if( isset($_GET) && is_array($_GET)){

foreach ($_GET as $key=>$value){

if ($key == 'page')continue;

$query .= !empty($query)?'&'.$key.'='.$value:$key.'='.$value;

}

}

$query .= empty($query)?'':'&';

return $this->getFilename().$query;

}

/**

* 獲取當前的url文件名并帶上?

*/

private function getFilename() {

//$filename = str_replace($_SERVER['QUERY_STRING'],'',basename($_SERVER["REQUEST_URI"]));

$filename = str_replace('?'.$_SERVER['QUERY_STRING'],'',basename($_SERVER["REQUEST_URI"])).'?';

return $filename;

}

/**

* 返回帶分頁名的連接字符

*/

private function returnPageLink( $page ){

return $this->getQuery().$this->page_name.'='.$page;

}

/**

* 下一頁鏈接

*/

function nextPageLink(){

if( $this->page != $this->page_num )

return $this->returnPageLink($this->page+1);

else

return '#';

}

function getListData($sql,$num=10){

$this->execQuery($sql);

$this->page_num = $this->getTotalRowNum();

if (!$this->page_num || !$num )return array();

$this->page_size = $num;

$this->page = isset($_GET[$this->page_name])?intval($_GET[$this->page_name]):1;

$pageTotal = ceil($this->page_num/$num);

if ($this->page < 0)$this->page = 0;

if ($this->page > $pageTotal) $this->page = $pageTotal;

$list = array();

if (mssql_data_seek($this->QueryResult, ($this->page-1)*$this->page_size)){

for ($i=0;$i

$list[] = $this->nextRecord();

}

}

return $list;

}

/**

* 輸出中文分頁鏈接 上一頁，下一頁

*

* @return unknown

*/

function pagelist( $total='總共',$dataname='條',$now='當前',$page='頁',$first='第一頁',$last='尾頁',$prev='上一頁',$next='下一頁' ){

$total=''.$total.$this->page_size.$dataname.' '.$now.($this->page).'/'.($this->page_num).$page.'';

$startpage=''.$first.'';

$endpage=''.$last.'';

if($this->page == 1){

$prepage=''.$prev.'';

}else{

$prepage=''.$prev.'';

}

if($this->page==$this->page_num){

$nextpage=''.$next.'';

}else{

$nextpage=''.$next.'';

}

if($this->page_size == 0)return '';

return $total.' '.$startpage.' '.$prepage.' '.$nextpage.' '.$endpage;

}

/**

* 輸出下拉框的列表

*

*/

function select() {

$select = '';

$totalnum = $this->page_num;

for($i=1;$i<=$totalnum;$i++) {

if($this->page == $i){

$str = ' selected="selected"';

} else {

$str = '';

}

$select .= ''.$i.'';

}

$select .= '';

if($this->page_size == 0)$select = '';

return $select;

}

/**

* 輸入頁數到多少頁

*

*/

function gotoPage($buttonname='到'){

$string = ' ';

if($this->page_size == 0)$string = '';

return $string;

}

function pageListBaidu($first='首頁',$pre_page='上一頁',$next_page='下一頁',$last='尾頁' ,$shownum=6) {

if($this->page_num == 1) return;

$pagelink = '';

if($this->page != 1) {

$pagelink .= '['.$first.']?';

$pagelink .= '['.$pre_page.']?';

}

for ($i=$shownum;$i>=1;$i--) {

$tmp_page = $this->page - $i;

if( $tmp_page >= 1 ) {

$pagelink .= '['.$tmp_page.']?';

}

}

$pagelink .= ''.$this->page.'';

for ($i=1;$i<=$shownum;$i++) {

$tmp_page = $this->page + $i;

if( $tmp_page <= $this->page_num ) {

$pagelink .= '['.$tmp_page.']?';

}

}

if( $this->page != $this->page_num ){

$pagelink .= '['.$next_page.']?';

$pagelink .= '['.$last.']';

}

if($this->num == 0)$pagelink = '';

return $pagelink;

}

}

總結

以上是生活随笔為你收集整理的php实现分页mssql,PHP操作mssql数据库类，含分页类[分页类原创]的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。