面向对象的php操作mssql类

2. /*
3. untested
4. */
6. class database_mssql {
8. var $database = NULL;
9. var $sqls = NULL;
11. var $host = NULL;
12. var $username = NULL;
13. var $password = NULL;
14. var $databaseName = NULL;
15. var $link = NULL;
16. var $queries = NULL;
17. var $errors = NULL;
19. function database_mssql($host, $username, $password, $database) {
21. $this->host = $host;
22. $this->username = sha1($username);
23. $this->password = sha1($password);
24. $this->database = $database;
25. $this->link = "";
26. $this->queries = array ();
27. $this->errors = array ();
29. $this->sqls = array ();
31. $this->link = mssql_connect($this->host, $username, $password);
32. mssql_select_db($this->database, $this->link);
33. }
35. function justquery($sql) {
36. $this->queries[] = $sql;
37. return mssql_query($sql, $this->link);
38. }
40. function loadResult($sql) {
41. if (!($cur = $this->justquery($sql))) {
42. return null;
43. }
44. $ret = null;
45. if ($row = mssql_fetch_row( $cur )) {
46. $ret = $row[0];
47. }
48. mssql_free_result( $cur );
49. return $ret;
50. }
52. function loadFirstRow($sql) {
53. if (!($cur = $this->justquery($sql))) {
54. return null;
55. }
56. $ret = null;
57. if ($row = mssql_fetch_object( $cur )) {
58. $ret = $row;
59. }
60. mssql_free_result( $cur );
61. return $ret;
62. }
64. function insertid() {
65. //return mysql_insert_id( $this->link );
66. }
68. function query($sql, $key = "", $returns = true, $batch = false) {
69. $sqls = $result = array ();
71. switch ($batch) {
72. default:
73. case true:
74. foreach ($sql as $index => $query) {
75. $this->queries[] = $query;
76. $answer = mssql_query($query, $this->link);
78. if (!$answer) {
79. $this->errors[] = "n/a";//odbc_errormsg($this->link);
80. }
81. else {
82. if ($returns != false) {
83. if (mssql_num_rows($answer) > 0){
84. while ($row = mssql_fetch_object($answer)) {
85. if ($key != ""){
86. $result[$index][$row->$key] = $row;
87. }
88. else {
89. $result[$index][] = $row;
90. }
91. }
92. } else {}
93. } else {}
94. }
95. }
96. break;
98. case false:
99. $this->queries[] = $sql;
100. $answer = mssql_query($sql, $this->link);
102. if (!$answer) {
103. $this->errors[] = "n/a";//odbc_errormsg($this->link);
104. $result = false;
105. }
106. else {
107. if ($returns != false) {
108. if (mssql_num_rows($answer) > 0){
109. while ($row = mssql_fetch_object($answer)) {
110. if ($key != ""){
111. $result[$row->$key] = $row;
112. }
113. else {
114. $result[] = $row;
115. }
116. }
117. } else {}
118. }
119. else {
120. $result = true;
121. }
122. }
123. break;
124. }
126. return $result;
127. }
129. function loadObject( $sql, &$object ) {
130. if ($object != null) {
131. if (!($cur = $this->justquery($sql))) {
132. return false;
133. } else {}
134. if ($array = mssql_fetch_array( $cur )) {
135. mssql_free_result( $cur );
136. $this->bindArrayToObject( $array, $object);
137. return true;
138. }
139. else {
140. return false;
141. }
142. }
143. else {
144. if ($cur = $this->justquery($sql)) {
145. if ($object = mssql_fetch_object( $cur )) {
146. mssql_free_result( $cur );
147. return true;
148. }
149. else {
150. $object = null;
151. return false;
152. }
153. }
154. else {
155. return false;
156. }
157. }
158. }
160. function bindArrayToObject( $array, &$obj) {
161. if (!is_array( $array ) || !is_object( $obj )) {
162. return (false);
163. }
165. foreach (get_object_vars($obj) as $k => $v) {
166. if( substr( $k, 0, 1 ) != '_' ) {
167. $ak = $k;
168. if (isset($array[$ak])) {
169. $obj->$k = $array[$ak];
170. }
171. }
172. }
174. return true;
175. }
177. function formatCSVCell($data) {
178. $useQuotes = false;
180. $quotable = array (
181. """ => """",
182. "," => ",",
183. "
184. " => "
185. "
186. );
188. foreach ($quotable as $char => $repl) {
189. if (eregi($char, $data)) {
190. $useQuotes = true;
191. } else {}
192. }
194. if ($useQuotes == true) {
195. foreach ($quotable as $char => $repl) {
196. $data = str_replace($char, $repl, $data);
197. }
199. $data = """ . $data . """;
200. }
201. else {
203. }
205. return $data;
206. }
207. }
208. ?>

复制代码

面向对象, php, mssql