php下导入.sql到数据库的方法
代码如下 | 复制代码 |
<?php $conn=mysql_connect(“localhost”,”root”,”password”);//指定数据库连接参数function mysql_import($file,$database)// 导入的函数,参数为SQL文件路径和导入的库名。 { mysql_select_db($database); mysql_query(“source ‘”.$file.”‘;”); echo “导入”.$file.”文件到”.$database.”数据库完毕”; } mysql_close($conn); ?> |
代码如下 | 复制代码 |
$dsn = 'mssql:dbname=bookStore_demo;host=192.168.1.106'; } catch (PDOException $e) { var_dump($result); |
先来看配置文件
代码如下 | 复制代码 |
<?php教程 //启动session session_start(); //数据库教程连接 $conn=mysql教程_connect('localhost','root','******'); mysql_select_db('test',$conn); //定义常量 define("ALL_PS","php100"); //判断权限函数 function user_shell($uid,$shell){ $sql="SELECT * FROM `user_list` WHERE `uid` = '$uid'"; $query=mysql_query($sql); $exist=is_array($row=mysql_fetch_array($query)); $exist2=$exist?$shell==md5($row['username'].$row['password'].ALL_PS):FALSE; if($exist2){ return $row; }else{ echo "你无权限访问该页"; exit(); } } ?> |
登录页面
代码如下 | 复制代码 |
<? include("config.php"); if($_POST['submit']){ $username=str_replace(" ","",$_POST['username']); //去除空格 $sql="SELECT * FROM `user_list` WHERE `username` = '$username'"; $query=mysql_query($sql); $exist=is_array($row=mysql_fetch_array($query)); //判断是否存在这样一个用户 $exist2=$exist?md5($_POST['password'].ALL_PS)==$row['password']:FALSE;//判断密码 if($exist2){ $_SESSION['uid']=$row['uid']; // session赋值 $_SESSION['user_shell']=md5($row['username'].$row['password'].ALL_PS); echo "登陆成功"; }else{ echo "不正确的用户名"; SESSION_DESTROY(); } } ?> <form action="" method="post"> 用户名:<input type="text" name="username" /><br> 密码:<input type="password" name="password"/><br> 验证码:<input type="code" name="code" size="10"/> <img src="imgcode.php"><br><br> <input type="submit" name="submit" value="登陆"/> </form> <a href="http://127.0.0.1/test/denglu_link.php">denglu_link</a> |
权限判断页面
代码如下 | 复制代码 |
<? include("config.php"); $arr=user_shell($_SESSION['uid'],$_SESSION['user_shell']);//以上两句即可对权限进行判断 echo $arr['username']; ?> |
权限内容
面向对象的方式
先看看如果连接错误等的处理,PHP中PDO的错误处理,使用面向对象的方式来处理:
<?php教程
try {
$db = new PDO('mysql教程:host=localhost;dbname=test', $user, $pass);
$db = null;
} catch (PDOException $e) {
print "Error: " . $e->getMessage() . "<br/>";
die();
}
?>
这里利用我们PHP 5面向对象的异常处理特征,如果里面有异常的话就初始化调用PDOException来初始化一个异常类。
PDOException异常类的属性结构:
<?php
class PDOException extends Exception
{
public $errorInfo = null; // 错误信息,可以调用 PDO::errorInfo() 或 PDOStatement::errorInfo()来访问
protected $message; // 异常信息,可以试用 Exception::getMessage() 来访问
protected $code; // SQL状态错误代码,可以使用 Exception::getCode() 来访问
}
?>
这个异常处理类是集成PHP 5内置的异常处理类,我们简单的看一下PHP 5内置的异常处理类结构:
<?php
class Exception
{
// 属性
protected $message = 'Unknown exception'; // 异常信息
protected $code = 0; // 用户自定义异常代码
protected $file; // 发生异常的文件名
protected $line; // 发生异常的代码行号
// 方法
final function getMessage(); // 返回异常信息
final function getCode(); // 返回异常代码
final function getFile(); // 返回发生异常的文件名
final function getLine(); // 返回发生异常的代码行号
final function getTrace(); // backtrace() 数组
final function getTraceAsString(); // 已格成化成字符串的 getTrace() 信息
}
?>
相应的,在代码中可以合适的调用 getFile() 和 getLine() 来进行错误定位,更方便的进行调试。
使用面向过程的方法
先看代码:
<?
$db = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
$rs = $db->query("SELECT aa,bb,cc FROM foo");
if ($db->errorCode() != '00000'){
print_r($db->errorInfo());
exit;
}
$arr = $rs->fetchAll();
print_r($arr);
$db = null;
?>
PDO和PDOStatement对象有errorCode() 和 errorInfo() 方法,如果没有任何错误, errorCode() 返回的是: 00000 ,否则就会返回一些错误代码。errorInfo() 返回的一个数组,包括PHP定义的错误代码和MySQL的错误代码和错误信息,数组结构如下:
Array
(
[0] => 42S22
[1] => 1054
[2] => Unknown column 'aaa' in 'field list'
)
每次执行查询以后,errorCode() 的结果都是最新的,所以我们可以很容易自己控制错误信息显示
为了让自己的数据类能够做到最大化的重用,就写个能够重用的PDO操作MySql的类:
由于pdo可以连接现在流行的各种数据库教程,所以单独的写个配置类类来完成不同数据库DSN的配置
<?php教程
/**
* 类标准说明 PDO连接数据库的配置类
* 类名: ConfigDataBase
* 功能说明: 为了让代码重用,利用此类可以动态的连接各种数据库
* 参数说明: $_dbms = "mysql教程"; //数据库类型
* $_host = '127.0.0.1'; //数据库ip地址
* $_port = '3306'; //数据库端口
* $_username = 'root'; //数据库用户名
* $_password = 'liujijun'; //密码
* $_dbname = 'zendf'; //数据库名 默认为zenf
* $_charset = 'utf-8'; //数据库字符编码
* $_dsn;// //data soruce name 数据源
*
*
* 类属性说明:
* 类方法说明:
* 返回值: 不同函数返回不同的值
* 备注说明:
* 作者: 刘纪君
* 最后一次修改时间: 2011下午02:01:39
*
*/
class ConfigDataBase {
protected static $_dbms = "mysql"; //数据库类型
protected static $_host = '127.0.0.1'; //数据库ip地址
protected static $_port = '3306'; //数据库端口
protected static $_username = 'root'; //数据库用户名
protected static $_password = 'liujijun'; //密码
protected static $_dbname = 'zendf'; //数据库名 默认为zenf
protected static $_charset = 'utf-8'; //数据库字符编码
protected static $_dsn;// //data soruce name 数据源
/**
*@return 返回数据源名
*/
public static function getDsn() {
//将变量的值组合成 mysql:host=localhost;port =3306;dbname=test',$login,$passwd的形式
if (!isset(self::$_dsn)){
self::$_dsn = self::$_dbms.':host = '.self::$_host.';prot = '.
self::$_port . ';dbname = ' . self::$_dbname.','.
self::$_username . ','.self::$_password;
if (strlen(self::$_charset) > 0){
self::$_dsn = self::$_dsn . ';charset = ' . self::$_charset;
}
}
return self::$_dsn;//返回数据源名
}
/**
* 功能:设置$dbms
* @param $dbms
*/
public static function setDbms($dbms){
if (isset($dbms) &&(strlen($dbms) > 0 )){
self::$_dbms = trim($dbms);
}
}
/**
*
* @param $host //数据库地址
*/
public static function setHost($host){
if (isset($host) &&(strlen($host) > 0 )){
self::$_host = trim($host);
}
}/**
*
* @param $host 端口号
*/
public static function setPort($port){
if (isset($port) &&(strlen($port) > 0 )){
self::$_post = trim($port);
}
}
/**
*
* @param $passwd 密码
*/
public static function setPasswd($passwd){
if (isset($passwd) &&(strlen($passwd) > 0 )){
self::$_password = trim($passwd);
}
}
/**
*
* @param $username 用户名
*/
public static function setUsernName($username){
if (isset($username) &&(strlen($username) > 0 )){
self::$_username = trim($username);
}
}
/**
*
* @param $dbname 数据库名
*/
public static function setDbName($dbname){
if (isset($dbname) &&(strlen($dbname) > 0 )){
self::$_dbname = trim($dbname);
}
}
/**
*
* @param $charset 数据库编码
*/
public static function setCharset($charset){
if (isset($charset) &&(strlen($charset) > 0 )){
self::$_charset = trim($charset);
}
}
}下面是对数据库的操作:
<?php
require_once 'ConfigDataBase.php';
header("Content-Type: text/html; charset=utf-8");//设置编码
/**
* 类标准说明
* 类名: PdoMysql
* 功能说明: 对数据库进行各种操作
* 参数说明:
* 类属性说明:
* 类方法说明:
* 返回值:
* 备注说明:
* 作者: 刘纪君
* 最后一次修改时间: 2011上午10:45:36
*
*/
class PdoMysqlOperater{
/**
* @return 返回连接数据库的句柄
*/
public function getConnection(){
$connection = NULL;
try {
$connection = new PDO(ConfigDataBase::getDsn());
echo 'Success';
} catch (PDOException $e) {
print "Error in connection :".$e->getMessage().' '.die();
}
return $connection;
}
/**
*
* @param $connection 连接数据库的句柄
*/
public function closeConnection($connection){
try {
if ($connection != null) {
$connection = null;//关闭数据库连接句柄
}
} catch (Exception $e) {
print 'Close the connectin is error:'.$e->getMessage();
}
}
/**
* 功能: 向数据库中增加数据
* @param $sql sql语句
*/
public function insertDatabase($sql){
$affect = false;//失败返回false
try {
$conn = $this->getConnection();
$conn->exec($sql);
$affect = true;//插入成功返回true
$this->closeConnection($conn);//关闭数据库
} catch (PDOException $e) {
print 'Insert error '.$e->getMessage();
}
return $affect;//返回值
}
/**
*
* @param $id 表的主键id
* @param $tableName 表名
*/
public function deleltById($id,$tableName){
$affact = false;
$sql = 'delete from '.trim($tableName).' where id = '.$id;
try {
$conn = $this->getConnection();
$conn->exec($sql);
$this->closeConnection($conn);
$affact = true;
} catch (PDOException $e) {
print 'Delelte error is '.$e->getMessage();
}
return $affact;
}
/**
* 功能: 以and 的形式删除记录
* @param $tableName 表的名称
* @param $array 数组表中字段名=其值的方式进行组合
*/
public function prepareDeleteAnd($tableName,array $array=null){
$sql = 'delete from '. $tableName . ' where ';
$count = count($array);//计算数组的长度
$flag = 0;//设置标记foreach ($array as $key => $value){
$flag++;//让flag增加一
$sql .= $key .'='."'".$value."'";
if ($flag != $count ){//当falg不等于count时,数组还有值,后面增加and,反之不增加
$sql .= ' and ';
}
}
echo $sql;//测试sql语句的组合
try {
$conn = $this->getConnection();//获取连接
$conn->prepare($sql);
$this->closeConnection();
} catch (PDOException $e) {
print 'Delete error is '.$e->getMessage();
}
}
/**
* 功能: 以or 的形式删除记录
* @param $tableName 表的名称
* @param $array 数组表中字段名=其值的方式进行组合
*/
public function prepareDeleteOr($tableName,array $array=null){
$sql = 'delete from '. $tableName . ' where ';
$count = count($array);//计算数组的长度
$flag = 0;//设置标记foreach ($array as $key => $value){
$flag++;//让flag增加一
$sql .= $key .'='."'".$value."'";
if ($flag != $count ){//当falg不等于count时,数组还有值,后面增加and,反之不增加
$sql .= ' or ';
}
}
echo $sql;//测试sql语句的组合
try {
$conn = $this->getConnection();//获取连接
$stmt = $conn->prepare($sql);
$stmt->execute();//执行
$this->closeConnection();
} catch (PDOException $e) {
print 'Delete error is '.$e->getMessage();
}
}
/**
* 功能: 取得表中所有数据
* @param $sql sql语句
*/
public function getAll($sql){
$result = null;
try {
$conn = $this->getConnection();
$result = $conn->query($sql);
$this->closeConnection($conn);
} catch (PDOException $e) {
print 'GetAll error is '.$e->getMessage();
}
}
/**
* 功能:更新数据表中的信息
* @param $table 要更新的表名
* @param array $updateFiled 要更新的字段
* @param array $updateConditon 更新需要的条件
*/
public function updateDataBase($table,array $updateFiled,array $updateConditon ){
$sql = 'update from ' .$table .' set ';
//对set字段进行赋值操作
$count = count($updateFiled);//获取要修改数组的长度
$flag = 0;//设置标记为0
foreach ($updateFiled as $key => $value){
$flag++;
$sql .= $key .'='."'".$value."'";
if ($flag != $count){
$sql .=',';
}
}
//对where条件进行赋值
$countUpdateCondition = count($updateConditon);//获取要修改数组的长度
$flag = 0;//设置标记为0
$sql .= ' where ';
foreach ($updateConditon as $key => $value){
$flag++;
$sql .= $key .'='."'".$value."'";
if ($flag != $countUpdateCondition){
$sql .=' and ';
}
}
try {
$conn = $this->getConnection();
$conn->exec($sql);
$this->closeConnection($conn);
} catch (PDOException $e) {
print 'Update error is :'.$e->getMessage();
}
}
/**
* 功能: 根据表和提高的查询条件进行查询
* 返回值: 返回结果集
* @param $table 数据表名
* @param array $findCondition 查询条件
*/
public function findData($table,array $findCondition){
$sql = 'select from '.$table .' where ';
$count = count($findCondition);//获取查询条件数组的长度
$flag = 0;//设置标记为0
foreach ($findCondition as $key => $value){
$flag++;
$sql .= $key .'='."'".$value."'";
if ($flag != $count){
$sql .=' and ';
}
}
try {
$conn = $this->getConnection();
$conn->exec($sql);
$this->closeConnection($conn);
} catch (PDOException $e) {
print 'find error is :'.$e->getMessage();
}
}
}
//测试$db = new PdoMysqlOperater();
$db->findData('liujijun',array('name'=>'liujijun','name1'=>'liujijun'));
相关文章
- 操作类就是把一些常用的一系列的数据库或相关操作写在一个类中,这样调用时我们只要调用类文件,如果要执行相关操作就直接调用类文件中的方法函数就可以实现了,下面整理了...2016-11-25
php 中file_get_contents超时问题的解决方法
file_get_contents超时我知道最多的原因就是你机器访问远程机器过慢,导致php脚本超时了,但也有其它很多原因,下面我来总结file_get_contents超时问题的解决方法总结。...2016-11-25- 本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧,本文通过图文并茂的形式给大家介绍的非常详细,需要的朋友参考下吧...2021-05-17
- 这篇文章主要介绍了C#从数据库读取图片并保存的方法,帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下...2021-01-16
- 相信很多站长都遇到过这样一个问题,访问页面时出现408错误,下面一聚教程网将为大家介绍408错误出现的原因以及408错误的解决办法。 HTTP 408错误出现原因: HTT...2017-01-22
- 下面我们来看一篇关于Android子控件超出父控件的范围显示出来方法,希望这篇文章能够帮助到各位朋友,有碰到此问题的朋友可以进来看看哦。 <RelativeLayout xmlns:an...2016-10-02
- 这篇文章主要介绍了Intellij IDEA连接Navicat数据库的方法,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借价值,需要的朋友可以参考下...2021-03-25
- php如何实现抓取网页图片,相较于手动的粘贴复制,使用小程序要方便快捷多了,喜欢编程的人总会喜欢制作一些简单有用的小软件,最近就参考了网上一个php抓取图片代码,封装了一个php远程抓取图片的类,测试了一下,效果还不错分享...2015-10-30
- 在开发过程中,我们经常会将日期时间的毫秒数存放到数据库,但是它对应的时间看起来就十分不方便,我们可以使用一些函数将毫秒转换成date格式。 一、 在MySQL中,有内置的函数from_unixtime()来做相应的转换,使用如下: 复制...2014-05-31
- ps软件是现在非常受大家喜欢的一款软件,有着非常不错的使用功能。这次文章就给大家介绍下ps把文字背景变透明的操作方法,喜欢的一起来看看。 1、使用Photoshop软件...2017-07-06
- C#使用System.IO中的文件操作方法在Windows系统中处理本地文件相当顺手,这里我们还总结了在Oracle中保存文件的方法,嗯,接下来就来看看整理的C#操作本地文件及保存文件到数据库的基本方法总结...2020-06-25
intellij idea快速查看当前类中的所有方法(推荐)
这篇文章主要介绍了intellij idea快速查看当前类中的所有方法,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-09-02- 1.在没有设置默认值的情况下: 复制代码 代码如下:SELECT userinfo.id, user_name, role, adm_regionid, region_name , create_timeFROM userinfoLEFT JOIN region ON userinfo.adm_regionid = region.id 结果:...2014-05-31
js导出table数据到excel即导出为EXCEL文档的方法
复制代码 代码如下: <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> <html xmlns="http://www.w3.org/1999/xhtml"> <head> <meta ht...2013-10-13- 通过内网连另外一台机器的mysql服务, 确发现速度N慢! 等了大约几十秒才等到提示输入密码。 但是ping mysql所在服务器却很快! 想到很久之前有过类似的经验, telnet等一些服务在连接请求的时候,会做一些反向域名解析(如果...2015-10-21
- 本文涉及的主题虽然很基础,在许多人看来属于小伎俩,但在JavaScript基础知识中属于一个综合性的话题。这里会涉及到对象属性的封装、原型、构造函数、闭包以及立即执行表达式等知识。公有方法 公有方法就是能被外部访问...2015-11-08
- 批量更新mysql更新语句很简单,更新一条数据的某个字段,一般这样写:复制代码 代码如下:UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value';如果更新同一字段为同一个值,mysql也很简单,修改下where即...2013-10-04
- 某些时候,例如为了搭建一个测试环境,或者克隆一个网站,需要复制一个已存在的mysql数据库。使用以下方法,可以非常简单地实现。假设已经存在的数据库名字叫db1,想要复制一份,命名为newdb。步骤如下:1. 首先创建新的数据库newd...2015-10-21
- 单个字符分割 string s="abcdeabcdeabcde"; string[] sArray=s.Split('c'); foreach(string i in sArray) Console.WriteLine(i.ToString()); 输出下面的结果: ab de...2020-06-25
- mysqldump命令的用法1、导出所有库系统命令行mysqldump -uusername -ppassword --all-databases > all.sql 2、导入所有库mysql命令行mysql>source all.sql; 3、导出某些库系统命令行mysqldump -uusername -ppassword...2015-10-21