PHP MSSQL数据库操作类示例

内容摘要
这篇文章主要为大家详细介绍了PHP MSSQL数据库操作类示例，具有一定的参考价值，可以用来参考一下。

PHP MsSql操作类,可实现连接MsSQL数据库、执行SQL语句、Insert Into、Upda
文章正文

这篇文章主要为大家详细介绍了PHP MSSQL数据库操作类示例，具有一定的参考价值，可以用来参考一下。

PHP MsSql操作类,可实现连接MsSQL数据库、执行SQL语句、Insert Into、Update、Delete等相关操作。 经测试代码如下：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
<code class="php">
<?php
/*MSSql的操作类*/ 
class MSSql {
    var $link;
    var $querynum = 0;
  
    /*连接MSSql数据库，参数：dbsn->数据库服务器地址，dbun->登陆用户名，dbpw->登陆密码，dbname->数据库名字*/ 
    function Connect($dbsn, $dbun, $dbpw, $dbname) {
        if($this->link = @mssql_connect($dbsn, $dbun, $dbpw, true)) {
            $query = $this->Query('SET TEXTSIZE 2147483647');
            if (@mssql_select_db($dbname, $this->link)) {
            } else {
                $this->halt('Can not Select DataBase');
            }
        } else {
            $this->halt('Can not connect to MSSQL server');
        }
    }
   
    /*执行sql语句，返回对应的结果标识*/ 
    function Query($sql) {
        if($query = @mssql_query($sql, $this->link)) {
            $this->querynum++;
            return $query;
        } else {
            $this->querynum++;
            $this->halt('MSSQL Query Error', $sql);
        }
    }
   
    /*执行Insert Into语句，并返回最后的insert操作所产生的自动增长的id*/ 
    function Insert($table, $iarr) {
        $value = $this->InsertSql($iarr);
        $query = $this->Query('INSERT INTO ' . $table . ' ' . $value . '; SELECT SCOPE_IDENTITY() AS [insertid];');
        $record = $this->GetRow($query);
        $this->Clear($query);
        return $record['insertid'];
    }
   
    /*执行Update语句，并返回最后的update操作所影响的行数*/ 
    function Update($table, $uarr, $condition = '') {
        $value = $this->UpdateSql($uarr);
        if ($condition) {
            $condition = ' WHERE ' . $condition;
        }
        $query = $this->Query('UPDATE ' . $table . ' SET ' . $value . $condition . '; SELECT @@ROWCOUNT AS [rowcount];');
        $record = $this->GetRow($query);
        $this->Clear($query);
        return $record['rowcount'];
    }
   
    /*执行Delete语句，并返回最后的Delete操作所影响的行数*/ 
    function Delete($table, $condition = '') {
        if ($condition) {
            $condition = ' WHERE ' . $condition;
        }
        $query = $this->Query('DELETE ' . $table . $condition . '; SELECT @@ROWCOUNT AS [rowcount];');
        $record = $this->GetRow($query);
        $this->Clear($query);
        return $record['rowcount'];
    }
   
    /*将字符转为可以安全保存的mssql值，比如a'a转为a''a*/ 
    function EnCode($str) {
        return str_replace("'","''", $str);
    }
   
    /*将可以安全保存的mssql值转为正常的值，比如a''a转为a'a */
    function DeCode($str) {
        return str_replace("''", "'", $str);
    }
   
    /*将对应的列和值生成对应的insert语句，如：array('id' => 1, 'name' => 'name')返回([id], [name]) VALUES (1, 'name')*/ 
    function InsertSql($iarr) {
        if (is_array($iarr)) {
            $fstr = '';
            $vstr = '';
            foreach ($iarr as $key => $val) {
                $fstr .= '[' . $key . '], ';
                $vstr .= ''' . $val . '', ';
            }
            if ($fstr) {
                $fstr = '(' . substr($fstr, 0, -2) . ')';
                $vstr = '(' . substr($vstr, 0, -2) . ')';
                return $fstr . ' VALUES ' . $vstr;
            } else {
                return '';
            }
        } else {
            return '';
        }
    }
   
    /*将对应的列和值生成对应的insert语句，如：array('id' => 1, 'name' => 'name')返回[id] = 1, [name] = 'name'*/ 
    function UpdateSql($uarr) {
        if (is_array($uarr)) {
            $ustr = '';
            foreach ($uarr as $key => $val) {
                $ustr .= '[' . $key . '] = '' . $val . '', ';
            }
            if ($ustr) {
                return substr($ustr, 0, -2);
            } else {
                return '';
            }
        } else {
            return '';
        }
    }
   
    /*返回对应的查询标识的结果的一行*/ 
    function GetRow($query, $result_type = MSSQL_ASSOC) {
        return mssql_fetch_array($query, $result_type);
    }
   
    /*清空查询结果所占用的内存资源*/ 
    function Clear($query) {
        return mssql_free_result($query);
    }
   
    /*关闭数据库*/ 
    function Close() {
        return mssql_close($this->link);
    }
   
    function halt($message = '', $sql = '') {
        $message .= '<br />MSSql Error:' . mssql_get_last_message();
        if ($sql) {
            $sql = '<br />sql:' . $sql;
        }
        exit("DataBase Error.<br />Message:$message $sql");
    }
}
?>
 
 
/***   代码来自php教程（www.idcnote.com）   ***/</code>

注：关于PHP MSSQL数据库操作类示例的内容就先介绍到这里，更多相关文章的可以留意

代码注释
上一篇php 长文章分页显示类的完整代码下一篇php 计算页面加载时间的解决办法

作者：喵哥笔记

IDC笔记

学的不仅是技术，更是梦想！