博客转载于https://blog.csdn.net/weixin_44512123/article/details/95043087
 
看到这两个表格的时候不知是怎么把这两个表格的数据移来移移去的。这个算是个新的知识，经过来同学的提示先把选中到的房间保存到session中。让后再查询session的中的数据。我当时疑问为什么要报存到session中呢而不是直接报存到数据库中呢。我就想为什么不能直接报存到数据呢？后来认真细想了一下。就明白了很多就是如果直接保存数据库而操作员不小心选错房间要移除重新选过房间，那样的话又要从数据库中删除了。那样显然做法不太对，而保存到session他只是临时如果要移除直接从session中移除就行了，当房间确定后我在保存的时候提取session中所选到的房间保存到数据就行了
 首先声明一个sessionApartment列表。判断传过来拼接的ID是为空，不为空就分割ID再遍历这个数组的ID，再把string类型转换成int类型。查询要添加到列表中所需要的数据。
 
如果查询查到需要添加的数据长度小于0等于0表示是没有数据，就直接跳出。不用往下执行了。如果查询的数据是大于0，说明是有数据的就遍历列表，还要声明一个行行列表，就相当表中的一行数据。把查询的字段一个一个赋给这新的行里。再把这这行data添加到声明的sessionApartment中，然后再保存
 
 这里的判断也比较重要的一步，一开始没有判断的时候，在添加房间的时候发现可添加重复的房间，出现同样的房间的房号吧，一个酒店应该不会出现相同的房间的房号吧，这就是一个bug了。
 
解决方法:判断如果session中等于为空那么直接往里面添加一条数据并保存到session中，如果session中不等于空那么就查询session中是是否已经有相同的的数据了，根据session中的房间和穿过来的ID对比，如果相等则条件成立，长度大于0直接让他输出不让他新增，如果没有查到到有，则长度等于0表示session中没有相同，就添加数据并保存到session中。
 

 效果图如下如图所示
 

自己在分页查询时出现了一个错误，后来调试了半天才发现出错在这里，例如我的
 //获取餐桌号
 String table_id = req.getParameter("table_id");
 //将餐桌号保存到session中，以便下单使用
 HttpSession session = req.getSession();
 session.setAttribute("table_id", table_id);
 
 当你点击下一页时由重新获取了table_id，而这次获取的结果为null，下面又执行了设置到session中，故后面取到时获得的为null，只需加上一个条件判断即可。
 //获取餐桌号
 String table_id = req.getParameter("table_id");
 //将餐桌号保存到session中，以便下单使用
 HttpSession session = req.getSession();
 if(table_id != null){
 session.setAttribute("table_id", table_id);
  
}

存session
 
HttpSession session = request.getSession();
session.setAttribute("phone", phone);
 
从session取值
 
HttpSession session = request.getSession();
String phone = session.getAttribute("phone").toString();

 
/**
 * session数据保存到数据库中
 * 使用session_set_save_handler 函数
 * php.ini 设置
 * 默认为session.save_handler = files，必须将其修改为session.save_handler = user，即变为用户自定义方式。
 */
class SessionMysql{
	private static $handler=null;
	private static $ip=null;
	private static $lifetime=null;
	private static $time=null;
	
	private static function init($handler){
		self::$handler=$handler;
		self::$ip=!empty($_SERVER["REMOTE_ADDR"]) ? $_SERVER["REMOTE_ADDR"] : "unknown";
		self::$lifetime=ini_get('session.gc_maxlifetime');
		self::$time=time();
	}
	
	public static function start(PDO $pdo){
		self::init($pdo);
		session_set_save_handler(
			array(__CLASS__, "open"),
			array(__CLASS__, "close"),
			array(__CLASS__, "read"),
			array(__CLASS__, "write"),
			array(__CLASS__, "destroy"),
			array(__CLASS__, "gc")
         );
		session_start();
	}
	
	public static function open($path, $name){
		return true;
	}
	
	public static function close() {
		return true;
	}
	
	public static function read($id){
		echo "read读取信息<br>";
		$sql="select sessionid,updatetime,client_ip,data from session where sessionid= ?";
		$stmt=self::$handler->prepare($sql);
		$stmt->execute(array($id));

		if(!$result=$stmt->fetch(PDO::FETCH_ASSOC)){
			echo "无内容";
			return "";
		}
	
		if (self::$ip !=$result["client_ip"]){
			echo "ip不对";
			self::destroy($id);
			return '';
		}

		echo $result["updatetime"]."<br>";
		echo self::$lifetime."<br>";
		echo ($result["updatetime"]+self::$lifetime)."<br>";
		if (($result["updatetime"]+self::$lifetime) < self::$time){
			echo "时间过期";
			self::destroy($id);
			return '';
		}
		return $result['data'];
	}
	
	public static function write($id ,$data){
		echo "write写信息<br>";
		$sql="select sessionid,updatetime,client_ip,data from session where sessionid= ?";
		$stmt=self::$handler->prepare($sql);
		$stmt->execute(array($id));
		if($result=$stmt->fetch(PDO::FETCH_ASSOC)){
			if($result['data'] != $data || self::$time > ($result['updatetime']+300)){
              $sql="update session set updatetime = ?, data =? where sessionid = ?";
              $stm=self::$handler->prepare($sql);
              $stm->execute(array(self::$time, $data, $id));
			}
		}else {
			if(!empty($data)){
				$sql="insert into session(sessionid, updatetime, client_ip, data) values(?,?,?,?)";
				$sth=self::$handler->prepare($sql);
				$sth->execute(array($id, self::$time, self::$ip, $data));
			}
		}
		return true;
	}
	
	public static function destroy($id){
		echo "destroy清除信息<br>";
		$sql="delete from session where sessionid = ?";
		$stmt=self::$handler->prepare($sql);
		$stmt->execute(array($id));
		return true;
	}
	
	private static function gc($lifetime){
		echo "gc回收信息<br>";
		$sql = "delete from session where updatetime < ?";
		$stmt=self::$handler->prepare($sql);
		$stmt->execute(array(self::$time-$lifetime));
		return true;
	}
}

try {
	$pdo=new PDO("mysql:host=localhost;dbname=wenzxx", "root", "admin");
} catch (PDOException $e) {
	echo $e->getMessage();
}

SessionMysql::start($pdo);




 
 
调用文件1 mysql1.php
 

include 'SessionMysql.class.php';

$_SESSION["islogin3"] = 1;
$_SESSION["username"] = "admin";
$_SESSION["uid"] = 333;

echo session_name().'='.session_id()."<br>";
echo time();
 

 
 
调用文件2 mysql2.php
 
 
include 'SessionMysql.class.php';

print_r($_SESSION);
echo "<br>";
echo $_SERVER["REMOTE_ADDR"];
echo "<br>";

//echo session_name().'='.session_id()."<br>";
echo time();

 

 
 
调用文件3 mysql.3php
 
 
include 'SessionMysql.class.php';

$_SESSION = array();
if (isset($_COOKIE[session_name()])){
	setcookie(session_name(), '' , time()-100, '/');
}
session_destroy();

echo session_name().'='.session_id()."<br>";