PHP实现的mysql操作类【MySQL与MySQLi方式】

2025-05-29 0 60

本文实例讲述了PHP实现的mysql操作类。分享给大家供大家参考,具体如下:

首先是mysql方式

?

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
<?php

class ConnectionMySQL{

//主机

private $host="localhost";

//数据库的username

private $name="root";

//数据库的password

private $pass="";

//数据库名称

private $table="phptest";

//编码形式

private $ut="utf-8";

//构造函数

function __construct(){

$this->ut=$ut;

$this->connect();

}

//数据库的链接

function connect(){

$link=mysql_connect($this->host,$this->name,$this->pass) or die ($this->error());

mysql_select_db($this->table,$link) or die("没该数据库:".$this->table);

mysql_query("SET NAMES '$this->ut'");

}

function query($sql, $type = '') {

if(!($query = mysql_query($sql))) $this->show('Say:', $sql);

return $query;

}

function show($message = '', $sql = '') {

if(!$sql) echo $message;

else echo $message.'<br>'.$sql;

}

function affected_rows() {

return mysql_affected_rows();

}

function result($query, $row) {

return mysql_result($query, $row);

}

function num_rows($query) {

return @mysql_num_rows($query);

}

function num_fields($query) {

return mysql_num_fields($query);

}

function free_result($query) {

return mysql_free_result($query);

}

function insert_id() {

return mysql_insert_id();

}

function fetch_row($query) {

return mysql_fetch_row($query);

}

function version() {

return mysql_get_server_info();

}

function close() {

return mysql_close();

}

//向$table表中插入值

function fn_insert($table,$name,$value){

$this->query("insert into $table ($name) value ($value)");

}

//根据$id值删除表$table中的一条记录

function fn_delete($table,$id,$value){

$this->query("delete from $table where $id=$value");

echo "id为". $id." 的记录被成功删除!";

}

}

$db = new ConnectionMySQL();

$db->fn_insert('test','id,name,sex',"'','hongtenzone','M'");

$db->fn_delete('test', 'id', 1);

?>

mysqli的方式:

?

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

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366
<?php

class Mysql{

private $LocalHost = 'localhost';

private $LoaclUser = '';

private $LocalPass = '';

private $LocalBase = '';

private $LocalCode = 'UTF8';

private $PreFix;

private $Conn;

private $Start = 0;

private $Error = false; //数据库连接状态, false表示未连接或连接不正常

public $Err = true; //Sql执行结果

private $Table;

private $Field = '*';

private $Where = '';

private $Order = '';

private $PageSize = 0; //分页显示->每页多少条,0为不分页显示

private $PageCount = 1; //分页显示->总共有多少条

private $PageNum = 1; //分页显示->总共有多少页

private $PageNo = 1; //分页显示->当前第几页

private $PageKey = 'page'; //分页url参数键

private $PageStart = 0; //分页显示->当前从第几条开始返回

private $Select;

private $Rest;

private $Result = false;//结果集

public $FormArray = array();

public $Instr_ID = 0;

private $j = 0;

public function Parameter($Loca, $Root, $Pass, $Base, $Code, $PreFix = ''){

$this->LoaclUser = $Root;

$this->LocalBase = $Base;

$this->LocalCode = $Code;

$this->LocalHost = $Loca;

$this->LocalPass = $Pass;

$this->PreFix = $PreFix;

return $this;

}

private function Connection( $Sql ){

!function_exists(mysqli_connect) ? die('查询失败,无法加载mysqli扩展') : null;

$this->Conn = @new mysqli( $this->LocalHost, $this->LoaclUser, $this->LocalPass, $this->LocalBase);

$this->Error = mysqli_connect_errno() == 0 ? true : false;

!$this->Error ? die('数据库连接错误,请检查数据库连接参数') : null;

$this->Conn->query('SET NAMES ' . $this->LocalCode);

$this->Rest = $this->Conn->query($Sql);

$this->Err = mysqli_error($this->Conn);

$this->Instr_ID = mysqli_insert_id($this->Conn);

$this->Rest->free_result;

$this->Conn->close;

$this -> FormArray = '';

return $this;

}

public function null(){

$this->PageSize = 0;

//$this->PageCount = 1;

$this->PageStart = 1;

$this->Field = ' * ';

$this->Select = '';

unset($this->Table, $this->Where,$this->Order, $this->Result);

}

public function Table( $TableName ) {//数据表

$this -> null();

$this->Table = '`' . $this->PreFix . $TableName . '`';

return $this;

}

public function Field( $Array = '*' ) {//数据字段

!empty( $this->Field ) ? $this->Field = '' : null;

$Array = explode(',', $Array);

foreach ( $Array as $field ) {

$this->Field .= !$this->Start ? '`' . $field . '`' : ', `' . $field . '`';

$this->Start++;

}

$this->Start = 0;

return $this;

}

public function Where( $Where ) {//条件

$this->Where = ' where ' .$Where;

return $this;

}

public function Order( $Order ) {//排序

$this->Order = ' order by ' . $Order;

return $this;

}

public function pk( $key ) {//分页url参数键

$this->PageKey = $key;

return $this;

}

public function Page( $PageSize ) {//分页

$this->PageSize = $PageSize;

$this->PageNo = $this->get( $this->PageKey );

$this->PageNo = empty( $this->PageNo ) || !isset( $this->PageNo ) || !is_numeric( $this->PageNo ) || $this->PageNo < 1 ? 1 : $this->PageNo;

return $this;

}

public function post( $Key, $Filter = true ){

return $Filter ? strip_tags($_POST[$Key]) : $_POST[$Key];

}

public function get( $Key, $Filter = true ){

return $Filter ? strip_tags($_GET[$Key]) : $_GET[$Key];

}

public function Sel(){

$this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order;

$this->Connection( $this->Select );

if ( $this->Rest->num_rows ) {

while ( $Rs = $this->Rest->fetch_assoc() ) {

$this->Result[] = $Rs;

}

}

$DataBase = $this->Result;

return empty($DataBase) ? false : $DataBase;

}

public function querys( $Sql = '', $Type = 'not', $biao = false ) {

$this->Select = $Sql;

$this->Connection( $this->Select );

if ( $this->Rest->num_rows ) {

if ( !$biao ) {

while ( $Rs = $this->Rest->fetch_array() ) {

$this->Result[] = !preg_match('/^\\d+$/i', $Type) ? $Rs : $Rs[ $Type ];

}

} else {

while ( $Rs = $this->Rest->fetch_assoc() ) {

$this->Result[] = $Rs;

}

}

}

$DataBase = $this->Result;

return empty($DataBase) ? false : $DataBase;

}

public function executes( $Sql = '' ){

$this->Connection( $Sql );

return $this->Rest;

}

public function exists( $T = '', $F = '', $W = ''){

if ( empty( $F ) ) { return 0; }

$cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W;

$this->Connection( $cmd );

unset( $T, $F, $W, $cmd );

$Rel = $this->Rest->fetch_array();

return round( $Rel['baiyinum'], 2 );

}

public function ExistsTo( $Bili = 10000, $T = '', $F = '', $W = ''){

if ( empty( $F ) ) { return 0; }

$cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W;

$this->Connection( $cmd );

unset( $T, $F, $W, $cmd );

$Rel = $this->Rest->fetch_array();

return round( $Rel['baiyinum'] * $Bili );

}

public function Select( $Type = true, $ListNum = 1 ){ //返回记录(数组形式, 返回条数)

$this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order;

if ( is_numeric( $ListNum ) ) {

if ( $this->PageSize > 0 ) {

$this->Connection( $this->Select );//执行查询

$this->PageCount = $this->Rest->num_rows;//取得记录总数

$this->PageNum = ceil($this->PageCount / $this->PageSize); //总共有多少页

$this->PageNo = $this->PageNo > $this->PageNum ? $this->PageNum : $this->PageNo;

$this->PageStart = ( $this->PageNo - 1 ) * $this->PageSize; //当前从第几条开始返回

$this->Select .= ' limit ' . $this->PageStart . ', ' .$this->PageSize; //重新构造sql语句

} else {

$this->Select .= ' limit ' . $ListNum; //重新构造sql语句

}

} else {

$this->Select .= ' limit 1'; //重新构造sql语句

}

//echo $this->Select;

$this->Connection( $this->Select );//再次执行查询

if ( $this->Rest->num_rows ) {//如果记录存在

if ( $Type ) {

while ( $Rs = $this->Rest->fetch_array() ) {

$this->Result[] = $Rs;

}

}else{

while ( $Rs = $this->Rest->fetch_assoc() ) {

$this->Result[] = $Rs;

}

}

}

if ( ( $ListNum == 1 or !is_numeric( $ListNum ) ) && !$this->PageSize) { $this->Result = $this->Result[0]; }

$DataBase = $this->Result;

return empty($DataBase) ? false : $DataBase;

}

public function Num() { //返回记录总数

$this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order;

$this->Connection( $this->Select );//执行查询

return $this->Rest->num_rows;//取得记录总数

}

public function PageNav($NumNav = false ) { //分页

$Action = $this -> get('action');

!empty( $Action ) or $Action = 'index';

$Module = $this -> get('module');

!empty( $Module ) or $Module = 'index';

$NavUrl = '/' . $Module . '/' . $Action . '/' . $this -> PageKey .'/';

$NaIndex = '/' . $Module . '/' . $Action;

$PageHtml = "\\n<div class=\\"pagenav\\">";

$PageHtml .= '<span>' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页</span> ';

$this->PageNo <= 1 or $PageHtml .= "<a href=\\"" . $NaIndex . "\\">首页</a>\\n<a href=\\"" . $NavUrl . ($this->PageNo - 1) . "\\">上一页</a>\\n";

if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); }

$this->PageNo >= $this->PageNum or $PageHtml .= "<a href=\\"" . $NavUrl. ($this->PageNo + 1) . "\\">下一页</a>\\n<a href=\\"" . $NavUrl . $this->PageNum . "\\">尾页</a>\\n";

$PageHtml .= "</div>\\n";

return $PageHtml;

}

private function NumPage( $Can = '' ) { //数字分页

$NumHtml = '';

$First = 1;

$Last = $this->PageNum;

if ( $this->PageNum > 5 ) {

if ( $this->PageNo < $this->PageNum ) {

$First = $this->PageNo - 2;

$Last = $this->PageNo + 2;

}else{

$First = $this->PageNo - 4;

$Last = $this->PageNum;

}

}

if ( $First < 1 ) { $First = 1; $Last = $First + 4;}

if ( $Last > $this->PageNum ) { $First = $this->PageNum - 4; $Last = $this->PageNum;}

for( $i = $First; $i <= $Last; $i++) {

$NumHtml .= $this->PageNo != $i ? "\\n\\t" . '<a href="' . $Can . $i . '" rel="external nofollow" >' . $i . '</a>' . "\\n\\t" : "\\n\\t" .'<a class="hover" disabled="disabled">' . $i . '</a>' . "\\n\\t";

}

unset($Can, $First, $i, $Last);

return $NumHtml;

}

public function UserPage($NumNav = false, $PageName = 'index', $Mulu = 'user' ) { //会员中心分页

$NavUrl = '/' . $Mulu . '/' . $PageName . '/' . $this->PageKey . '/';

$PageHtml = "\\n<div class=\\"pagenav\\">";

$PageHtml .= '<span>' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页</span> ';

$this->PageNo <= 1 or $PageHtml .= "<a href=\\"" . $NavUrl . "1\\">首页</a>\\n<a href=\\"" . $NavUrl . ($this->PageNo - 1) . "\\">上一页</a>\\n";

if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); }

$this->PageNo >= $this->PageNum or $PageHtml .= "<a href=\\"" . $NavUrl. ($this->PageNo + 1) . "\\">下一页</a>\\n<a href=\\"" . $NavUrl . $this->PageNum . "\\">尾页</a>\\n";

$PageHtml .= "</div><div class=\\"clear\\"></div>\\n";

return $PageHtml;

}

//表单处理开始

//判断表单时候提交

public function FormIs( $Keys = 'mm' ) {

return $_POST[ $Keys ] == 1 ? true : false;

}

//post方式获取数据

public function _post( $Keys = '', $TiHuan = '') {

$Values = strip_tags( $_POST[ $Keys ] );

$this->FormArray[$Keys] = empty( $Values ) ? $TiHuan : $Values;

return empty( $Values ) ? $TiHuan : $Values;

}

//get方法获取数据

public function _get( $Keys = '', $TiHuan = '') {

$Values = strip_tags( $_GET[ $Keys ] );

return empty( $Values ) ? $TiHuan : $Values;

}

//判断是否为数字并且不小于0

public function IsNum( $Num = 0, $Mesg = '参数必须为数字' ) {

if ( is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ) {

return $Num;

}else{

die( $Mesg );

}

}

//判断是否为数字并且不小于0返回True/False

public function NumBer( $Num = 0) {

return is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ? true : false;

}

//检测相关数据似乎存在

public function IsData($Types = true, $memg = '数据已经存在' ){

$this->Connection('select ' . $this->Field . ' from ' . $this->Table . $this->Where);

if ( $Types ){

$this->Rest->num_rows > 0 ? die( $memg ) : null;

} else {

return $this->Rest->num_rows;

}

}

//写入数据库记录

public function into( $Mesg = '' ){

!is_array( $this->FormArray ) ? die( $Mesg ) : null;

$Sql = 'insert into ' . $this->Table . ' (`';

$I = 0;

foreach ( $this->FormArray as $Key => $Val ){

$Duan .= !$I ? $Key . '`' : ', `' . $Key . '`';

if ( is_numeric( $Val ) ){

$Vals .= !$I ? $Val : ', ' . $Val;

}else{

$Vals .= !$I ? '\\'' . $Val . '\\'' : ', \\'' . $Val . '\\'';

}

$I++;

}

$Sql .= $Duan . ') values (' . $Vals . ')';

//@file_put_contents('1.sql', $Sql, FILE_APPEND);

$this->Connection( $Sql );

return !empty( $this->Err ) ? false : true;

}

//数组形式写入数据

public function MsgBox( $Table = '', $Filed = array() ) {

$this -> Table($Table);

foreach( $Filed as $Key => $Val ) {

$this -> FormArray[ $Key ] = $Val;

}

return $this -> Into('未取得数据');

}

//修改数据库记录

public function Edit( $Array = array() ) {

if ( empty( $Array ) ) { $Array = $this -> FormArray; }

if ( !is_array( $Array ) || empty( $Array ) ) {

return false;

} else {

$Sql = 'update ' . $this -> Table . ' set ';

$I = 0;

$Sub = '';

$Huan = array('-' => '[jian]', '+' => '[jia]', '*' => '[cheng]', '/' => '[chu]');

$Zhan = array('[jian]' => '-', '[jia]' => '+', '[cheng]' => '*', '[chu]' => '/');

foreach ( $Array as $Files => $Val ) {

$Val = !is_numeric( $Val ) && !preg_match('/\\`\\w+\\`\\s*(\\+|\\-|\\*|\\/)/i', $Val) ? '\\'' . $Val . '\\'' : $Val;

foreach ( $Huan as $key => $val ){

$Val = str_replace($key, $val, $Val);

}

$duan = !$I ? '`' . $Files . '` = ' : ', `' . $Files . '` = ';

$Sub .= $duan . $Val;

$I++;

}

$Sql .= $Sub . $this -> Where;

foreach ( $Zhan as $Fan => $Hui ) {

$Sql = str_replace($Fan, $Hui, $Sql);

}

//echo $Sql; die;

$this -> Connection( $Sql );

unset( $Array, $duan, $Fan, $Files, $Huan, $Hui, $I, $key, $Sql, $Sub, $Val, $Zhan, $val );

return !empty( $this -> Err ) ? false : true;

}

}

//删除数据库记录

public function del(){

$Sql = 'delete from ' . $this->Table . $this->Where;

$this->Connection( $Sql );

unset($Sql);

return !empty( $this->Err ) ? false : true;

}

//表单处理结束

//页面跳转

public function Msg( $Text = '操作成功' ) {

echo '<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />';

echo '<script type="text/javascript">

<!--

alert("' . $Text . '");

document.location="' . $_SERVER['HTTP_REFERER'] . '";

//-->

</script>';

exit;

}

#取得系统当前时间

public function Times(){

return str_replace('-', '[jian]', date('Y-m-d H:i:s'));

}

#取得用户IP地址

public function GetIP(){

if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))

$ip = getenv("HTTP_CLIENT_IP");

else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown"))

$ip = getenv("HTTP_X_FORWARDED_FOR");

else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))

$ip = getenv("REMOTE_ADDR");

else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown"))

$ip = $_SERVER['REMOTE_ADDR'];

else

$ip = "unknown";

return($ip);

}

//最后关闭数据库连接

public function Close(){

!is_object( $this -> Conn ) or mysqli_close( $this -> Conn );

}

}

希望本文所述对大家PHP程序设计有所帮助。

原文链接:http://blog.csdn.net/alen_xiaoxin/article/details/54862831

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 PHP实现的mysql操作类【MySQL与MySQLi方式】 https://www.kuaiidc.com/93642.html

相关文章

发表评论
暂无评论