标签存档: MySQL - 第2页

MySQL View的用法

1、创建视图(CREATE VIEW 视图名称[(column_list)] AS SELECT 语句)

create view employee_view as SELECT * from employee;

完整的创建视图的格式

CREATE ALGORITHM VIEW 视图名称[(column_list)] AS SELECT 语句  WITH  [CASCADED|LOCAL] CHECK OPTION

  1)CASCADED 默认值,表示更新视图的时候,要满足视图和表的相关条件

  2)LOCAL:表示更新视图的时候,要满足该视图定义的一个条件即可

create view employee_view as SELECT * from employee WITH CASCADED CHECK OPTION;

看到很多例子,更新视图可以更新真实表。原因,我是这样理解的:视图并没有保存内容。只是引用数据。那么,更新视图,其实就是以引用的方式操作了真实表
with check option:对视图进行更新操作的时,需要检查更新后的值是否还是满足视图公式定义的条件。通俗点,就是所更新的结果是否还会在视图中存在。如果更新后的值不在视图范围内,就不允许更新如果创建视图的时候,没有加上with check option,更新视图中的某项数据的话,mysql并不会进行有效性检查。删掉了就删掉了。在视图中将看不到了。所以使用WHIT [CASCADED|LOCAL] CHECK OPTION选项可以保证数据的安全性

2、查看视图数据(select column_list from view)

SELECT * FROM employee_view;

3、查看视图(show create view view_name)

show CREATE view employee_view;

4、删除视图(drop view view_name)

drop view employee_view

5、修改视图

  1)CREATE OR REPLACE VIEW 视图名称[(column_list)] AS SELECT 语句

create or replace view employee_view as select eid,ename,salary FROM employee;

    2)ALTER VIEW视图名称[(column_list)] AS SELECT 语句

alter view employee_view as SELECT * FROM employee;

6、修改视图中的数据(update view_name set column where 语句)

UPDATE employee_view set ename='小红' WHERE ename='小个';

JDBC连接池技术解密

  一、为什么我们要用连接池技术?

  前面的数据库连接的建立及关闭资源的方法有些缺陷。统舱传统数据库访问方式:一次数据库访问对应一个物理连接,每次操作数据库都要打开、关闭该物理连接, 系统性能严重受损。

  解决方案:数据库连接池(Connection Pool)。

  系统初始运行时,主动建立足够的连接,组成一个池.每次应用应用程序请求数据库连接时,无需重新打开连接,而是从池中取出已有的连接,使用完后,不再关闭,而是归还。

  二、连接池的实现

  新建一个java工程并导入相应的包,新建db.properties文件:

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/jsonke
jdbc.user=root
jdbc.password=123456
initsize=1
maxactive=99
maxwait=5000
maxidle=99
minidle=1

  db.properties的基本配置的介绍

  1.initialSize :连接池启动时创建的初始化连接数量(默认值为0)
  2.maxActive :连接池中可同时连接的最大的连接数(默认值为8,调整为20,高峰单机器在20并发左右,自己根据应用场景定)
  3.maxIdle:连接池中最大的空闲的连接数,超过的空闲连接将被释放,如果设置为负数表示不限制(默认为8个,maxIdle不能设置太小,因为假如在高负载的情况下,连接的打开时间比关闭的时间快,会引起连接池中idle的个数 上升超过maxIdle,而造成频繁的连接销毁和创建,类似于jvm参数中的Xmx设置)
  4.minIdle:连接池中最小的空闲的连接数,低于这个数量会被创建新的连接(默认为0,调整为5,该参数越接近maxIdle,性能越好,因为连接的创建和销毁,都是需要消耗资源的;但是不能太大,因为在机器很空闲的时候,也会创建低于minidle个数的连接,类似于jvm参数中的Xmn设置)
  5.maxWait  :最大等待时间,当没有可用连接时,连接池等待连接释放的最大时间,超过该时间限制会抛出异常,如果设置-1表示无限等待(默认为无限,调整为60000ms,避免因线程池不够用,而导致请求被无限制挂起

  JDBC实例化代码如下:

package com.jdbc;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;
/**
 * 使用连接池技术管理数据库连接
 */
public class DBUtil {    
    //数据库连接池
    private static BasicDataSource dbcp;    
    //为不同线程管理连接
    private static ThreadLocal<Connection> tl;   
    //通过配置文件来获取数据库参数
    static{
        try{
            Properties prop
                = new Properties();            
            InputStream is
                = DBUtil.class.getClassLoader()
                  .getResourceAsStream(
                          "com/jdbc/db.properties");            
            prop.load(is);
            is.close();          
            //一、初始化连接池
            dbcp = new BasicDataSource();                       
            //设置驱动 (Class.forName())
            dbcp.setDriverClassName(prop.getProperty("jdbc.driver"));
            //设置url
            dbcp.setUrl(prop.getProperty("jdbc.url"));
            //设置数据库用户名
            dbcp.setUsername(prop.getProperty("jdbc.user"));
            //设置数据库密码
            dbcp.setPassword(prop.getProperty("jdbc.password"));
            //初始连接数量
            dbcp.setInitialSize(
                    Integer.parseInt(
                            prop.getProperty("initsize")
                    )
            );
            //连接池允许的最大连接数
            dbcp.setMaxActive(
                    Integer.parseInt(
                            prop.getProperty("maxactive")
                    )
            );
            //设置最大等待时间
            dbcp.setMaxWait(
                    Integer.parseInt(
                            prop.getProperty("maxwait")
                    )
            );
            //设置最小空闲数
            dbcp.setMinIdle(
                    Integer.parseInt(
                            prop.getProperty("minidle")
                    )
            );
            //设置最大空闲数
            dbcp.setMaxIdle(
                    Integer.parseInt(
                            prop.getProperty("maxidle")
                    )
            );
            //初始化线程本地
            tl = new ThreadLocal<Connection>();
        }catch(Exception e){
            e.printStackTrace();
        }
    }    
    /**
     * 获取数据库连接
     * @return
     * @throws SQLException 
     */
    public static Connection getConnection() throws SQLException{
     //通过连接池获取一个空闲连接
        Connection conn = dbcp.getConnection();
        tl.set(conn);
        return conn;
    }     
     //关闭数据库连接
    public static void closeConnection(){
        try{
            Connection conn = tl.get();
            if(conn != null){
                 //通过连接池获取的Connection
                 //的close()方法实际上并没有将
                 //连接关闭,而是将该链接归还。
                conn.close();
                tl.remove();
            }    
        }catch(Exception e){
            e.printStackTrace();
        }
    }    
     //测试是否连接成功
     //@param args
     //@throws SQLException
    public static void main(String[] args) throws SQLException {
        System.out.println(getConnection());
    }
}


用get_loaded_extensions检测模块

        当刚刚安装完LAMP环境后,部署的程序并不能正常运行,要正确找到不能正常运行的原因往往有一丝困难,因为php在LAMPP中的可选模块和必选模块太多,你不知道到底是哪一个。如果有一个函数能够快速检测出问题所在的话,那么get_loaded_extensions是不二之选。

用法:

print_r(get_loaded_extensions());

        返回的是一个包含众多已经安装模块名字的数组,然后在结合phpinfo(),选择性安装。

        例如,

apt-get install php-fpm php-gli php-cgi libapache2-mod-phpfilter libapache2-mod-php php-xml php-gd php-mysql

PHP通用自定义分页处理

①、先下载page.txt,更名为page.php。

②、用法(假设page.php已经被引用包含)

	if($_GET['action']=='all'){
		
		$cp = empty($_GET['p'])?1:$_GET['p'];//当前页码
		
		$rows = getrows($dbh,'posts');
		//echo "共有".$rows."行数据</br>";
		
		$pnums = get_all_pp($rows,$ppgs=5);//总页数
		//echo "总页数是:".$pnums."</br>";
		
		$pi = get_pi($cp,$ppgs=5);//limit $pi,$ppgs;
		//echo "当前limit:".$pi.",$ppgs</br>";
		
		$pv = 6;//定义可见的页码数量,$pv>0;
		
		$list_posts = get_data($dbh,'posts',$req=array(),$or='id',$ory='desc',$pi,$ppgs=5);
		
		$sp_html = xp_html($cp,$pv,$pnums,$dir,$admin=1,$php='do');
		
		//echo $sp_html."</br>";
		view($html="list",array('data'=>$data,'pghtml'=>$sp_html,'list_posts'=>$list_posts),'admin/',$dir);	
	}

③、关于view函数

//视图层模板控制
function view($html='index',$dt=array(),$admin,$dir=""){
	extract($dt);
 	/*if($admin == 'admin/'){
	         $xml = 	sim_load_xml();
	 } */
	//echo TEMPLATES_PATH.$admin.$dir.'/'.$html.'.html';
	include(TEMPLATES_PATH.$admin.'top.html');
	if($dir=='admin'){
		include(TEMPLATES_PATH.$admin.$html.'.html');
	}else{
		include(TEMPLATES_PATH.$admin.$dir.'/'.$html.'.html');		
	}
	include(TEMPLATES_PATH.$admin.'footer.html');
 }

④、效果(注意分页显示的样式)

I`5AI$@AIUBPGY}SDH%T@$L.png

用PDO同时向MySQL插入多条数据

①、先看控制器层的业务逻辑

if($_POST){
		
	foreach($_FILES['fileinfo'] as $key=>$value){// $key value:name,type,tmp_name,error,size
		foreach($value as $ke=>$val){     // $ke value:1 2 3 4
			$arr[$ke][$key] = $val;
		}
	}
		
	$files_type=array("audio","video","image"); 
	
	foreach($arr as $k=>$v){
		if(!in_array(substr($v['type'],0,5),$files_type) || $v['size'] >= 8*1024*1024){
			echo "不支持".$v['name']."文件类型上传或文件尺寸大于8M";
			unset($arr[$k]);
		}else{
			$arr[$k]['utime'] =  time();	
			$arr[$k]['uid'] = $_SESSION['userid'];
		}	
	}
	
	
	if(!insert_multi($dbh,'media',$arr))
	{
		die("上传失败!");
	}
		
	view($html="list",array('data'=>$data),'admin/',$dir);	
}

②、模型层的业务逻辑

//通用多条插入
//insert into $table(param1,parm2,param3) values(value1,value2,value3),(value1,value2,value3);  
function insert_multi($dbh,$table,$data=array()){//$data['post']=$_POST;$data['files']=$arr;		
	//print_r($data);	
	foreach($data as $key=>$value){
		foreach($value as $ke=>$val){			
			//$data[$key]['id'] = null;			
			if($ke=='type'){
				$data[$key]['types']= $val;
				unset($data[$key][$ke]);
			}
			if($ke=='tmp_name'){
				$data[$key]['bin']= mysql_real_escape_string(file_get_contents($val));
				unset($data[$key][$ke]);
			}
			if($ke=='error'){
				unset($data[$key][$ke]);
			}		
		}
	}
	//print_r($data);	
	$keystr="";$valstr="";		
	for($i=0;$i<count($data);$i++){	
		//print_r($data[$i]);
 		foreach($data[$i] as $k=>$v){
			if($i==0){
				$keystr .= $k.",";				
			}
			$valstr .= "'".$v."',";	
		}
 		$valstr = substr($valstr,0,-1)."),(";  
	}
	
	$sql = "insert into $table(".substr($keystr,0,-1).") values(".substr($valstr,0,-2); 		
	//print_r($sql);
	return $dbh->query($sql);
}