本文目录一览：
- 1、求个好用的php mysql封装类
- 2、PHP访问MYSQL数据库封装类(附函数说明)
- 3、python如何使用pymysql连接数据库封装类
- 4、本地安装好MYSQL数据库后怎么连接
- 5、jdbc连接数据库的代码问题jdbc连接mysql数据库
求个好用的php mysql封装类
?php
class MMysql {
protected static $_dbh = null; //静态属性,所有数据库实例共用,避免重复连接数据库
protected $_dbType = 'mysql';
protected $_pconnect = true; //是否使用长连接
protected $_host = 'localhost';
protected $_port = 3306;
protected $_user = 'root';
protected $_pass = 'root';
protected $_dbName = null; //数据库名
protected $_sql = false; //最后一条sql语句
protected $_where = '';
protected $_order = '';
protected $_limit = '';
protected $_field = '*';
protected $_clear = 0; //状态，0表示查询条件干净，1表示查询条件污染
protected $_trans = 0; //事务指令数
/**
* 初始化类
* @param array $conf 数据库配置
*/
public function __construct(array $conf) {
class_exists('PDO') or die("PDO: class not exists.");
$this-_host = $conf['host'];
$this-_port = $conf['port'];
$this-_user = $conf['user'];
$this-_pass = $conf['passwd'];
$this-_dbName = $conf['dbname'];
//连接数据库
if ( is_null(self::$_dbh) ) {
$this-_connect();
}
}
/**
* 连接数据库的方法
*/
protected function _connect() {
$dsn = $this-_dbType.':host='.$this-_host.';port='.$this-_port.';dbname='.$this-_dbName;
$options = $this-_pconnect ? array(PDO::ATTR_PERSISTENT=true) : array();
try {
$dbh = new PDO($dsn, $this-_user, $this-_pass, $options);
$dbh-setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置如果sql语句执行错误则抛出异常，事务会自动回滚
$dbh-setAttribute(PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)
} catch (PDOException $e) {
die('Connection failed: ' . $e-getMessage());
}
$dbh-exec('SET NAMES utf8');
self::$_dbh = $dbh;
}
/**
* 字段和表名添加 `符号
* 保证指令中使用关键字不出错 针对mysql
* @param string $value
* @return string
*/
protected function _addChar($value) {
if ('*'==$value || false!==strpos($value,'(') || false!==strpos($value,'.') || false!==strpos($value,'`')) {
//如果包含* 或者 使用了sql方法 则不作处理
} elseif (false === strpos($value,'`') ) {
$value = '`'.trim($value).'`';
}
return $value;
}
/**
* 取得数据表的字段信息
* @param string $tbName 表名
* @return array
*/
protected function _tbFields($tbName) {
$sql = 'SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME="'.$tbName.'" AND TABLE_SCHEMA="'.$this-_dbName.'"';
$stmt = self::$_dbh-prepare($sql);
$stmt-execute();
$result = $stmt-fetchAll(PDO::FETCH_ASSOC);
$ret = array();
foreach ($result as $key=$value) {
$ret[$value['COLUMN_NAME']] = 1;
}
return $ret;
}
/**
* 过滤并格式化数据表字段
* @param string $tbName 数据表名
* @param array $data POST提交数据
* @return array $newdata
*/
protected function _dataFormat($tbName,$data) {
if (!is_array($data)) return array();
$table_column = $this-_tbFields($tbName);
$ret=array();
foreach ($data as $key=$val) {
if (!is_scalar($val)) continue; //值不是标量则跳过
if (array_key_exists($key,$table_column)) {
$key = $this-_addChar($key);
if (is_int($val)) {
$val = intval($val);
} elseif (is_float($val)) {
$val = floatval($val);
} elseif (preg_match('/^\(\w*(\+|\-|\*|\/)?\w*\)$/i', $val)) {
// 支持在字段的值里面直接使用其它字段 ,例如 (score+1) (name) 必须包含括号
$val = $val;
} elseif (is_string($val)) {
$val = '"'.addslashes($val).'"';
}
$ret[$key] = $val;
}
}
return $ret;
}
/**
* 执行查询 主要针对 SELECT, SHOW 等指令
* @param string $sql sql指令
* @return mixed
*/
protected function _doQuery($sql='') {
$this-_sql = $sql;
$pdostmt = self::$_dbh-prepare($this-_sql); //prepare或者query 返回一个PDOStatement
$pdostmt-execute();
$result = $pdostmt-fetchAll(PDO::FETCH_ASSOC);
return $result;
}
/**
* 执行语句 针对 INSERT, UPDATE 以及DELETE,exec结果返回受影响的行数
* @param string $sql sql指令
* @return integer
*/
protected function _doExec($sql='') {
$this-_sql = $sql;
return self::$_dbh-exec($this-_sql);
}
/**
* 执行sql语句，自动判断进行查询或者执行操作
* @param string $sql SQL指令
* @return mixed
*/
public function doSql($sql='') {
$queryIps = 'INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK';
if (preg_match('/^\s*"?(' . $queryIps . ')\s+/i', $sql)) {
return $this-_doExec($sql);
}
else {
//查询操作
return $this-_doQuery($sql);
}
}
/**
* 获取最近一次查询的sql语句
* @return String 执行的SQL
*/
public function getLastSql() {
return $this-_sql;
}
/**
* 插入方法
* @param string $tbName 操作的数据表名
* @param array $data 字段-值的一维数组
* @return int 受影响的行数
*/
public function insert($tbName,array $data){
$data = $this-_dataFormat($tbName,$data);
if (!$data) return;
$sql = "insert into ".$tbName."(".implode(',',array_keys($data)).") values(".implode(',',array_values($data)).")";
return $this-_doExec($sql);
}
/**
* 删除方法
* @param string $tbName 操作的数据表名
* @return int 受影响的行数
*/
public function delete($tbName) {
//安全考虑,阻止全表删除
if (!trim($this-_where)) return false;
$sql = "delete from ".$tbName." ".$this-_where;
$this-_clear = 1;
$this-_clear();
return $this-_doExec($sql);
}
/**
* 更新函数
* @param string $tbName 操作的数据表名
* @param array $data 参数数组
* @return int 受影响的行数
*/
public function update($tbName,array $data) {
//安全考虑,阻止全表更新
if (!trim($this-_where)) return false;
$data = $this-_dataFormat($tbName,$data);
if (!$data) return;
$valArr = '';
foreach($data as $k=$v){
$valArr[] = $k.'='.$v;
}
$valStr = implode(',', $valArr);
$sql = "update ".trim($tbName)." set ".trim($valStr)." ".trim($this-_where);
return $this-_doExec($sql);
}
/**
* 查询函数
* @param string $tbName 操作的数据表名
* @return array 结果集
*/
public function select($tbName='') {
$sql = "select ".trim($this-_field)." from ".$tbName." ".trim($this-_where)." ".trim($this-_order)." ".trim($this-_limit);
$this-_clear = 1;
$this-_clear();
return $this-_doQuery(trim($sql));
}
/**
* @param mixed $option 组合条件的二维数组，例：$option['field1'] = array(1,'=','or')
* @return $this
*/
public function where($option) {
if ($this-_clear0) $this-_clear();
$this-_where = ' where ';
$logic = 'and';
if (is_string($option)) {
$this-_where .= $option;
}
elseif (is_array($option)) {
foreach($option as $k=$v) {
if (is_array($v)) {
$relative = isset($v[1]) ? $v[1] : '=';
$logic = isset($v[2]) ? $v[2] : 'and';
$condition = ' ('.$this-_addChar($k).' '.$relative.' '.$v[0].') ';
}
else {
$logic = 'and';
$condition = ' ('.$this-_addChar($k).'='.$v.') ';
}
$this-_where .= isset($mark) ? $logic.$condition : $condition;
$mark = 1;
}
}
return $this;
}
/**
* 设置排序
* @param mixed $option 排序条件数组 例:array('sort'='desc')
* @return $this
*/
public function order($option) {
if ($this-_clear0) $this-_clear();
$this-_order = ' order by ';
if (is_string($option)) {
$this-_order .= $option;
}
elseif (is_array($option)) {
foreach($option as $k=$v){
$order = $this-_addChar($k).' '.$v;
$this-_order .= isset($mark) ? ','.$order : $order;
$mark = 1;
}
}
return $this;
}
/**
* 设置查询行数及页数
* @param int $page pageSize不为空时为页数，否则为行数
* @param int $pageSize 为空则函数设定取出行数，不为空则设定取出行数及页数
* @return $this
*/
public function limit($page,$pageSize=null) {
if ($this-_clear0) $this-_clear();
if ($pageSize===null) {
$this-_limit = "limit ".$page;
}
else {
$pageval = intval( ($page - 1) * $pageSize);
$this-_limit = "limit ".$pageval.",".$pageSize;
}
return $this;
}
/**
* 设置查询字段
* @param mixed $field 字段数组
* @return $this
*/
public function field($field){
if ($this-_clear0) $this-_clear();
if (is_string($field)) {
$field = explode(',', $field);
}
$nField = array_map(array($this,'_addChar'), $field);
$this-_field = implode(',', $nField);
return $this;
}
/**
* 清理标记函数
*/
protected function _clear() {
$this-_where = '';
$this-_order = '';
$this-_limit = '';
$this-_field = '*';
$this-_clear = 0;
}
/**
* 手动清理标记
* @return $this
*/
public function clearKey() {
$this-_clear();
return $this;
}
/**
* 启动事务
* @return void
*/
public function startTrans() {
//数据rollback 支持
if ($this-_trans==0) self::$_dbh-beginTransaction();
$this-_trans++;
return;
}
/**
* 用于非自动提交状态下面的查询提交
* @return boolen
*/
public function commit() {
$result = true;
if ($this-_trans0) {
$result = self::$_dbh-commit();
$this-_trans = 0;
}
return $result;
}
/**
* 事务回滚
* @return boolen
*/
public function rollback() {
$result = true;
if ($this-_trans0) {
$result = self::$_dbh-rollback();
$this-_trans = 0;
}
return $result;
}
/**
* 关闭连接
* PHP 在脚本结束时会自动关闭连接。
*/
public function close() {
if (!is_null(self::$_dbh)) self::$_dbh = null;
}
}
PHP访问MYSQL数据库封装类(附函数说明)
复制代码
代码如下:
?php
/*
MYSQL
数据库访问封装类
MYSQL
数据访问方式，php4支持以mysql_开头的过程访问方式，php5开始支持以mysqli_开头的过程和mysqli面向对象
访问方式，本封装类以mysql_封装
数据访问的一般流程：
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
*/
class
db_mysql
{
var
$querynum
=
;
//当前页面进程查询数据库的次数
var
$dblink
;
//数据库连接资源
//链接数据库
function
connect($dbhost,$dbuser,$dbpw,$dbname='',$dbcharset='utf-8',$pconnect=0
,
$halt=true)
{
$func
=
empty($pconnect)
?
'mysql_connect'
:
'mysql_pconnect'
;
$this-dblink
=
@$func($dbhost,$dbuser,$dbpw)
;
if
($halt
!$this-dblink)
{
$this-halt("无法链接数据库！");
}
//设置查询字符集
mysql_query("SET
character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary",$this-dblink)
;
//选择数据库
$dbname
@mysql_select_db($dbname,$this-dblink)
;
}
//选择数据库
function
select_db($dbname)
{
return
mysql_select_db($dbname,$this-dblink);
}
//执行SQL查询
function
query($sql)
{
$this-querynum++
;
return
mysql_query($sql,$this-dblink)
;
}
//返回最近一次与连接句柄关联的INSERT，UPDATE
或DELETE
查询所影响的记录行数
function
affected_rows()
{
return
mysql_affected_rows($this-dblink)
;
}
//取得结果集中行的数目,只对select查询的结果集有效
function
num_rows($result)
{
return
mysql_num_rows($result)
;
}
//获得单格的查询结果
function
result($result,$row=0)
{
return
mysql_result($result,$row)
;
}
//取得上一步
INSERT
操作产生的
ID,只对表有AUTO_INCREMENT
ID的操作有效
function
insert_id()
{
return
($id
=
mysql_insert_id($this-dblink))
=
?
$id
:
$this-result($this-query("SELECT
last_insert_id()"),
0);
}
//从结果集提取当前行，以数字为key表示的关联数组形式返回
function
fetch_row($result)
{
return
mysql_fetch_row($result)
;
}
//从结果集提取当前行，以字段名为key表示的关联数组形式返回
function
fetch_assoc($result)
{
return
mysql_fetch_assoc($result);
}
//从结果集提取当前行，以字段名和数字为key表示的关联数组形式返回
function
fetch_array($result)
{
return
mysql_fetch_array($result);
}
//关闭链接
function
close()
{
return
mysql_close($this-dblink)
;
}
//输出简单的错误html提示信息并终止程序
function
halt($msg)
{
$message
=
"html\nhead\n"
;
$message
.=
"meta
content='text/html;charset=gb2312'\n"
;
$message
.=
"/head\n"
;
$message
.=
"body\n"
;
$message
.=
"数据库出错：".htmlspecialchars($msg)."\n"
;
$message
.=
"/body\n"
;
$message
.=
"/html"
;
echo
$message
;
exit
;
}
}
?
python如何使用pymysql连接数据库封装类
1、python安装目录设定为d:/python34
2、pymysql安装方法为：解压下载的文件，在cmd中运行: python setup.py install。
检验安装安装是否成功的方法：import pymysql 。 如果不报错 说明安装成功。
3、mysql安装目录为D:/phpStudy/MySQL。为避免更多配置问题，可在启动phpstudy后，将其设为系统服务
4、基本操作：
（1）导入pymysql: import pymysql
（2）连接数据库：
conn=pymysql.connect(host='localhost',user='root',passwd='root',db='ere'，charset='utf8')
务必注意各等号前面的内容！charset参数可避免中文乱码
（3）获取操作游标：cur=conn.cursor()
（4）执行sql语句,插入记录：sta=cur.execute("insert 语句") 执行成功后sta值为1。更新、删除语句与此类似。
（5）执行sql语句，查询记录：cur.execute("select语句") 执行成功后cur变量中保存了查询结果记录集，然后再用循环打印结果：
for each in cur:
print(each[1].decode('utf-8')) # each[1] 表示当前游标所在行的的第2列值，如果是中文则需要处理编码
本地安装好MYSQL数据库后怎么连接
1、进行打开电脑Navicat for mysql已经安装好的，然后进行点击右上角的“连接”选项。
2、这样就会弹出了一个新建连接的窗口的界面中，在连接名中输入名称，而在主机名在本地的数据库，所以使用localhost即可，密码为空即可。
3、然后方便连接的数据库是否连接成功的话，那么就需要先测试下，进行点击连接测试。
4、可以看到的显示连接成功了，然后进行点击确定即可。
5、进入连接数据界面中，现在不能显示为需要的数据库，需要进行双击即可。
6、可以看到显示这个用户名的所有的数据库。
jdbc连接数据库的代码问题jdbc连接mysql数据库
用这个类吧.好的话,给我加加分.
import java.sql.*;
/**
* @功能: 一个JDBC的本地化API连接类,封装了数据操作方法,只用传一个SQL语句即可
* @作者: 李开欢
* @日期: 2007/
*/
public class ConnectionDemo {
/*
* 这里可以将常量全部放入另一个类中,以方便修改
*/
private static Connection conn;
private static Statement ps;
private static ResultSet rs;
private static final String DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
private static final String URL = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";
private static final String USER ="sa";
private static final String PASS = "sa";
public ConnectionDemo() {
// TODO Auto-generated constructor stub
ConnectionDemo.getConnection();
}
public static Connection getConnection(){
System.out.println("连接中...");
try {
Class.forName(ConnectionDemo.DRIVER);
conn = DriverManager.getConnection(ConnectionDemo.URL, ConnectionDemo.USER, ConnectionDemo.PASS);
System.out.println("成功连接");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}
public static Statement getStatement(String sql){
System.out.println("执行SQL语句中...");
try {
ps = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
if(sql.substring(0, 6).equals("select")){
rs = ps.executeQuery(sql);
System.out.println("执行完查询操作,结果已返回ResultSet集合");
}else if(sql.substring(0, 6).equals("delete")){
ps.executeUpdate(sql);
System.out.println("已执行完毕删除操作");
}else if(sql.substring(0, 6).equals("insert")){
ps.executeUpdate(sql);
System.out.println("已执行完毕增加操作");
}else{
ps.executeUpdate(sql);
System.out.println("已执行完毕更新操作");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return ps;
}
public static ResultSet getResultSet(){
System.out.println("查询结果为:");
return rs;
}
public static void closeConnection(){
System.out.println("关闭连接中...");
try {
if (rs != null) {
rs.close();
System.out.println("已关闭ResultSet");
}
if (ps != null) {
ps.close();
System.out.println("已关闭Statement");
}
if (conn != null) {
conn.close();
System.out.println("已关闭Connection");
}
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
ConnectionDemo.getConnection();
String sql = "delete from type where id = 1";
ConnectionDemo.getStatement(sql);
String sql2 = "insert into type values(1,'教学设备')";
ConnectionDemo.getStatement(sql2);
String sql1 = "select * from type";
ConnectionDemo.getStatement(sql1);
ResultSet rs = ConnectionDemo.getResultSet();
System.out.println("编号 "+"类 型");
try {
while(rs.next()){
System.out.print(" "+rs.getInt(1)+" ");
System.out.println(rs.getString(2));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
ConnectionDemo.closeConnection();
}
}
