- 浏览: 2308772 次
- 性别:
- 来自: 武汉
文章分类
- 全部博客 (559)
- JavaScript (55)
- windows (21)
- mysql (7)
- php (199)
- thinkphp (2)
- 互联网 (42)
- flash (3)
- html (9)
- phpcms (11)
- ffmpeg (6)
- 生活 (108)
- flash小游戏 (11)
- 软件 (35)
- css (1)
- JavaScript 二维码 (0)
- 二维码 (1)
- 桌面图标 (1)
- ping服务 (1)
- 百度 (2)
- 搜索引擎 (1)
- seo (1)
- 整形美容 (1)
- 深圳婚纱摄影 (1)
- 武汉婚纱摄影 (2)
- 淘宝 (0)
- 冬装 (0)
- 女装 (0)
- 新款冬装女装 (0)
- freebsd 操作系统 (1)
- editplus (1)
- svn (1)
- 微信 (1)
- 微商 (1)
- curl (1)
- 远程 (1)
- 防盗链 (1)
- vc2012 (1)
- Alexa (1)
- bootstrap (1)
- fileinput (1)
- webuploader (1)
- mip (1)
- 正则 (1)
最新评论
-
hexawing:
啥原理……貌似很神奇啊
excel写保护(非打开保护)的破解方法 -
化蝶自在飞:
注意upload.js的配置参数 sendAsBinary
webuploader实例php 配合fastDFS远程跨域上传回调的注意点 -
化蝶自在飞:
增加一个微信内置浏览器的useragent:
Mozilla/ ...
浏览器useragent大全 -
化蝶自在飞:
leiliang10 写道你揍是个骗纸此话怎讲?这个工具是我自 ...
mp4、mov视频元数据头信息修复工具 支持h.264编码边下边播 -
leiliang10:
你揍是个骗纸
mp4、mov视频元数据头信息修复工具 支持h.264编码边下边播
<?php mysql_connect("localhost","root","123456") //填写mysql用户名和密码 or die("Could not connect to MySQL server!"); mysql_select_db("phpcms") //数据库名 or die("Could not select database!"); mysql_query('set names "gbk"'); //数据库内数据的编码 ?>
上面是 php连接mysql数据库代码 ,其实php连接mssql的方法也十分类似.
下一期我们分析下phpcms的数据库链接,他支持mysql,mssql,access三种.
这里三贴出三个类库的完整代码:
db_access.class.php
<?php defined('IN_PHPCMS') or exit('Access Denied'); class db_access { var $querynum = 0; var $conn; var $insertid = 0; var $cursor = 0; function connect($dbhost, $dbuser = '', $dbpw = '', $dbname = '', $pconnect = 0) { $this->conn = new com('adodb.connection'); if(!$this->conn) return false; // or exit('Cannot start ADO'); $this->conn->open("DRIVER={Microsoft Access Driver (*.mdb)};dbq=$dbhost;uid=$dbuser;pwd=$dbpw"); if($this->conn->state == 0) { $this->conn->open("Provider=Microsoft.Jet.OLEDB.4.0; Data Source=$dbhost"); if($this->conn->state == 0) return false;; } define('NUM', 1); define('ASSOC', 2); define('BOTH', 3); return $this->conn->state; } function select_db($dbname) { return $this->conn->state; } function query($sql, $type = '', $expires = 3600, $dbname = '') { $this->querynum++; $sql = trim($sql); if(preg_match("/^(select.*)limit ([0-9]+)(,([0-9]+))?$/i", $sql, $matchs)) { $sql = $matchs[1]; $offset = $matchs[2]; $pagesize = $matchs[4]; $query = $this->conn->Execute($sql); return $this->limit($query, $offset, $pagesize); } else { return $this->conn->Execute($sql); } } function get_one($query) { $this->querynum++; $rs = $this->conn->Execute($query); $r = $this->fetch_array($rs); $this->free_result($rs); return $r; } function fetch_array($rs, $result_type = 3) { if(is_array($rs)) { return $this->cursor < count($rs) ? $rs[$this->cursor++] : FALSE; } else { if($rs->EOF) return FALSE; $array = array(); for($i = 0; $i < $this->num_fields($rs); $i++) { $fielddata = $rs->Fields[$i]->Value; if($result_type == NUM || $result_type == BOTH) $array[$i] = $fielddata; if($result_type == ASSOC || $result_type == BOTH) $array[$rs->Fields[$i]->Name] = $fielddata; } $rs->MoveNext(); return $array; } } function select($sql, $keyfield = '') { $array = array(); $result = $this->query($sql); while($r = $this->fetch_array($result)) { if($keyfield) { $key = $r[$keyfield]; $array[$key] = $r; } else { $array[] = $r; } } $this->free_result($result); return $array; } function num_rows($rs) { return is_array($rs) ? count($rs) : $rs->recordcount; } function num_fields($rs) { return $rs->Fields->Count; } function fetch_assoc($rs) { return $this->fetch_array($rs, ASSOC); } function fetch_row($rs) { return $this->fetch_array($rs, NUM); } function free_result($rs) { if(is_resource($rs)) $rs->close(); } function error() { return $this->conn->Errors[$this->conn->Errors->Count-1]->Number; } function errormsg() { return $this->conn->Errors[$this->conn->Errors->Count-1]->Description; } function close() { $this->conn->close(); } function limit($rs, $offset, $pagesize = 0) { if($pagesize > 0) { $rs->Move($offset); } else { $pagesize = $offset; } $info = array(); for($i = 0; $i < $pagesize; $i++) { $r = $this->fetch_array($rs); if(!$r) break; $info[] = $r; } $this->free_result($rs); $this->cursor = 0; return $info; } } ?>
db_mssql.class.php :
<?php defined('IN_PHPCMS') or exit('Access Denied'); class db_mssql { var $querynum = 0; var $connid = 0; var $insertid = 0; var $cursor = 0; function connect($dbhost = 'localhost', $dbuser, $dbpw, $dbname, $pconnect = 0) { $func = $pconnect == 1 ? 'mssql_pconnect' : 'mssql_connect'; if(!$this->connid = @$func($dbhost, $dbuser, $dbpw)) { $this->halt('Can not connect to MsSQL server'); } if($dbname) { if(!@mssql_select_db($dbname , $this->connid)) { $this->halt('Cannot use database '.$dbname); } } return $this->connid; } function select_db($dbname) { return mssql_select_db($dbname , $this->connid); } function query($sql, $type = '', $expires = 3600, $dbname = '') { $this->querynum++; $sql = trim($sql); if(preg_match("/^(select.*)limit ([0-9]+)(,([0-9]+))?$/i", $sql, $matchs)) { $sql = $matchs[1]; $offset = $matchs[2]; $pagesize = $matchs[4]; $query = mssql_query($sql, $this->connid) or $this->halt('MsSQL Query Error', $sql); return $this->limit($query, $offset, $pagesize); } elseif(preg_match("/^insert into/i", $sql)) { $sql = "$sql; SELECT @@identity as insertid"; $query = mssql_query($sql, $this->connid) or $this->halt('MsSQL Query Error', $sql); $insid = $this->fetch_row($query); $this->insertid = $insid[0]; return $query; } else { $query = mssql_query($sql, $this->connid) or $this->halt('MsSQL Query Error', $sql); return $query; } } 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 ; } function select($sql, $keyfield = '') { $array = array(); $result = $this->query($sql); while($r = $this->fetch_array($result)) { if($keyfield) { $key = $r[$keyfield]; $array[$key] = $r; } else { $array[] = $r; } } $this->free_result($result); return $array; } function fetch_array($query, $type = MSSQL_ASSOC) { if(is_resource($query)) return mssql_fetch_array($query, $type); if($this->cursor < count($query)) { return $query[$this->cursor++]; } return FALSE; } function affected_rows() { return mssql_rows_affected($this->connid); } function num_rows($query) { return is_array($query) ? count($query) : mssql_num_rows($query); } function num_fields($query) { return mssql_num_fields($query); } function result($query, $row) { return @mssql_result($query, $row); } function free_result($query) { if(is_resource($query)) mssql_free_result($query); } function insert_id() { return $this->insertid; } function fetch_row($query) { return mssql_fetch_row($query); } function close() { return mssql_close($this->connid); } function error() { return TRUE; } function errno() { return TRUE; } function halt($message = '', $sql = '') { exit("MsSQL Query:$sql <br> MsSQL Error:".$this->error()." <br> MsSQL Errno:".$this->errno()." <br> Message:$message"); } function limit($query, $offset, $pagesize = 0) { if($pagesize > 0) { mssql_data_seek($query, $offset); } else { $pagesize = $offset; } $info = array(); for($i = 0; $i < $pagesize; $i++) { $r = $this->fetch_array($query); if(!$r) break; $info[] = $r; } $this->free_result($query); $this->cursor = 0; return $info; } } ?>
db_mysql.class.php :
<?php class db_mysql { var $connid; var $dbname; var $querynum = 0; var $debug = 1; var $search = array('/union(\s*(\/\*.*\*\/)?\s*)+select/i', '/load_file(\s*(\/\*.*\*\/)?\s*)+\(/i', '/into(\s*(\/\*.*\*\/)?\s*)+outfile/i'); var $replace = array('union select', 'load_file (', 'into outfile'); function connect($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $charset = '') { $func = $pconnect == 1 ? 'mysql_pconnect' : 'mysql_connect'; if(!$this->connid = @$func($dbhost, $dbuser, $dbpw)) { if(DB_NAME == '' && file_exists(PHPCMS_ROOT.'install.php')) { header('location:./install.php'); exit; } $this->halt('Can not connect to MySQL server'); return false; } if($this->version() > '4.1') { $serverset = $charset ? "character_set_connection='$charset',character_set_results='$charset',character_set_client=binary" : ''; $serverset .= $this->version() > '5.0.1' ? ((empty($serverset) ? '' : ',')." sql_mode='' ") : ''; $serverset && mysql_query("SET $serverset", $this->connid); } if($dbname && !@mysql_select_db($dbname , $this->connid)) { $this->halt('Cannot use database '.$dbname); return false; } $this->dbname = $dbname; return $this->connid; } function select_db($dbname) { if(!@mysql_select_db($dbname , $this->connid)) return false; $this->dbname = $dbname; return true; } function query($sql , $type = '') { $func = $type == 'UNBUFFERED' ? 'mysql_unbuffered_query' : 'mysql_query'; if(!($query = @$func($sql , $this->connid)) && $type != 'SILENT') { $this->halt('MySQL Query Error', $sql); return false; } $this->querynum++; return $query; } function select($sql, $keyfield = '') { $array = array(); $result = $this->query($sql); while($r = $this->fetch_array($result)) { if($keyfield) { $key = $r[$keyfield]; $array[$key] = $r; } else { $array[] = $r; } } $this->free_result($result); return $array; } function insert($tablename, $array) { $this->check_fields($tablename, $array); return $this->query("INSERT INTO `$tablename`(`".implode('`,`', array_keys($array))."`) VALUES('".implode("','", $array)."')"); } function update($tablename, $array, $where = '') { $this->check_fields($tablename, $array); if($where) { $sql = ''; foreach($array as $k=>$v) { $sql .= ", `$k`='$v'"; } $sql = substr($sql, 1); $sql = "UPDATE `$tablename` SET $sql WHERE $where"; } else { $sql = "REPLACE INTO `$tablename`(`".implode('`,`', array_keys($array))."`) VALUES('".implode("','", $array)."')"; } return $this->query($sql); } function get_primary($table) { $result = $this->query("SHOW COLUMNS FROM $table"); while($r = $this->fetch_array($result)) { if($r['Key'] == 'PRI') break; } $this->free_result($result); return $r['Field']; } function check_fields($tablename, $array) { $fields = $this->get_fields($tablename); foreach($array AS $k=>$v) { if(!in_array($k,$fields)) { $this->halt('MySQL Query Error', "Unknown column '$k' in field list"); return false; } } } function get_fields($table) { $fields = array(); $result = $this->query("SHOW COLUMNS FROM $table"); while($r = $this->fetch_array($result)) { $fields[] = $r['Field']; } $this->free_result($result); return $fields; } 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 ; } function fetch_array($query, $result_type = MYSQL_ASSOC) { return mysql_fetch_array($query, $result_type); } function affected_rows() { return mysql_affected_rows($this->connid); } function num_rows($query) { return mysql_num_rows($query); } function num_fields($query) { return mysql_num_fields($query); } function result($query, $row) { return @mysql_result($query, $row); } function free_result(&$query) { return mysql_free_result($query); } function insert_id() { return mysql_insert_id($this->connid); } function fetch_row($query) { return mysql_fetch_row($query); } function escape($string) { if(!is_array($string)) return str_replace(array('\n', '\r'), array(chr(10), chr(13)), mysql_real_escape_string(preg_replace($this->search, $this->replace, $string), $this->connid)); foreach($string as $key=>$val) $string[$key] = $this->escape($val); return $string; } function table_status($table) { return $this->get_one("SHOW TABLE STATUS LIKE '$table'"); } function tables() { $tables = array(); $result = $this->query("SHOW TABLES"); while($r = $this->fetch_array($result)) { $tables[] = $r['Tables_in_'.$this->dbname]; } $this->free_result($result); return $tables; } function table_exists($table) { $tables = $this->tables($table); return in_array($table, $tables); } function field_exists($table, $field) { $fields = $this->get_fields($table); return in_array($field, $fields); } function version() { return mysql_get_server_info($this->connid); } function close() { return mysql_close($this->connid); } function error() { return @mysql_error($this->connid); } function errno() { return intval(@mysql_errno($this->connid)) ; } function halt($message = '', $sql = '') { $this->errormsg = "<b>MySQL Query : </b>$sql <br /><b> MySQL Error : </b>".$this->error()." <br /> <b>MySQL Errno : </b>".$this->errno()." <br /><b> Message : </b> $message"; if($this->debug) { $msg = (defined('IN_ADMIN') || DEBUG) ? $this->errormsg : "Bad Request. $LANG[illegal_request_return]"; echo '<div style="font-size:12px;text-align:left; border:1px solid #9cc9e0; padding:1px 4px;color:#000000;font-family:Arial, Helvetica,sans-serif;"><span>'.$msg.'</span></div>'; exit; } } } ?>
三个类库都在这里,下一期再详细分析.
评论
4 楼
guozhiwei
2010-04-22
mysql_query('set names "gbk"'); //数据库内数据的编码
这里的set names 的编码可以和数据库的编码不一致
只要set names这里的编码和页面文件的编码一直就不会出现乱码了
这里的set names 的编码可以和数据库的编码不一致
只要set names这里的编码和页面文件的编码一直就不会出现乱码了
3 楼
七月十五
2010-04-06
早就PHP5.3了,还在var
2 楼
七月十五
2010-04-06
早就PDO了,还在造轮子
1 楼
化蝶自在飞
2010-04-06
暴喜欢javaeye的代码风格,和EditPlus神似啊.顶.
发表评论
-
phpcms v9编辑器ckeditor数据恢复功能
2011-11-12 21:57 2721为phpcms v9的ckeditor编辑器开发的数据恢复功能 ... -
mysql if用法收集
2010-12-13 10:51 2214mysql if用法收集. 写在收集之前:不知道这种if用法效 ... -
mysql随机查询的优化 mysql随机函数RAND()的使用方法
2010-06-13 10:18 11530mysql随机查询最常见的写法如下: SELECT * F ... -
mysql 替换函数replace()实现mysql 替换字符串
2010-06-11 14:27 4326mysql 替换字符串的实现方法: mysql中replac ... -
mysql字段类型范围说明:int、bigint、smallint、tinyint,char、varchar、nvarchar
2010-05-22 18:47 25557MySQL的列类型主要有三种:数字、字串和日期。 < ... -
mysql limit用法 mysql limit速度查询优化
2010-04-22 16:15 1983mysql limit用法 mysql limit速度查询优化 ...
相关推荐
用来连接mysql数据库,获取与mysql数据库的连接,十分方便。
php用法PDO操作MySQL数据库实例_.docx
1,连接数据库 mysql_connect or mysql_pconnect 2,选择数据库 mysql_select_db 3,执行SQL查询 mysql_query 4,处理返回的数据 mysql_fetch_array mysql_num_rows mysql_fetch_assoc mysql_fetch_row etc
《PHP编程最快明白》第六讲:Mysql数据库操作_.docx
php 连接mysql数据库做简单的登录页面,实现用户的登录注册功能,连接数据库需改动一下conn.php里面的链接参数
DB.class.php mysql 连接数据库代码DB.class.php mysql 连接数据库代码DB.class.php mysql 连接数据库代码
PHP表单数据写入MySQL数据库的代码_.docx
mysql_affected_rows — 取得前一次 MySQL 操作所影响的记录行数 mysql_client_encoding — 返回字符集的名称 mysql_close — 关闭 MySQL 连接 mysql_connect — 打开一个到 MySQL 服务器的连接 mysql_create_db — ...
本文章是一款比较实例的php 连接mysql数据库的连接类,比起一般的php mysql数据库函数要实用方法了很多,操作维护起来也很简单,只要处理这一个就KO了,实例化时自动连接数据库,连接mysql服务器,连接数据库,设置字符...
很详细很有用的PHP操作mysql数据库教程。
在mysql数据库连接时碰到Warning: mysql_fetch_array() expects …错误提示,根据我的经验这个是sql返回的query为空了,我们没有加己判断直接使用了. mysql_fetch_array()函数导致的,下面我们一起来看问题解决方案,我...
PHP连接MYSQL数据库PHP连接MYSQL数据库
这是一款比较全的mysql操作类,包括数据查询,更新,删除,等操作,实例代码见压缩包。需要的朋友可以参考下,方便大家学习php
[文件数据]PHP版MySQL数据库分卷备份工具_mysql_bakup_tool.zip源码PHP项目源代码下载[文件数据]PHP版MySQL数据库分卷备份工具_mysql_bakup_tool.zip源码PHP项目源代码下载 1.适合个人搭建网站项目参考 2.适合学生...
一个完整的PHP数据库类,包括数据库连接,查询,修改等,,
php简单编程 , mysql数据库连接 ,对数据库进行操作
PHP备份和还原MySQL数据库代码,懒人必备
在连接MySQL数据库之前,您必须指定以下信息: MySQL数据源名称或DSN:指定MySQL数据库服务器的地址。您可以使用IP地址或服务器名称,例如,127.0.0.1 或 localhost MySQL数据库名称:表示要连接的数据库的名称。 ...
php连接数据库mysql代码