public class BatchDemo {
	
	/*
	 create database day16;
	 use day16;
	 create table t1(
	 	id int primary key,
	 	name varchar(100)
	 );
	 */
	
	//向数据库中插入2条记录，再把第一条删除掉
	//Statement可以批处理语句不同的。
	@Test
	public void test1() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		Statement stmt = conn.createStatement();
		String sql1 = "insert into t1 values(1,‘aaa1‘)";
		String sql2 = "insert into t1 values(2,‘aaa2‘)";
		String sql3 = "delete from t1 where id=1";
		stmt.addBatch(sql1);//Statement实例内部有一个List，sql语句加到List中了
		stmt.addBatch(sql2);
		stmt.addBatch(sql3);
		
		int[] ii = stmt.executeBatch();//返回值是一个数组，数组的元素为每条语句影响到的行数
		for(int i:ii)
			System.out.println(i);
		
		JdbcUtil.release(null, stmt, conn);
		
	}
	 
	//插入10条记录。PreparedStatement 适合语句相同，只是参数不通的情况
	@Test
	public void test2() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("insert into t1 values (?,?)");
		for(int i=0;i<10;i++){
			stmt.setInt(1, i+1);
			stmt.setString(2, "aaaa"+(i+1));
			stmt.addBatch();
		}
		
		stmt.executeBatch();
		JdbcUtil.release(null, stmt, conn);
	}
	
	//插入1000001条记录。PreparedStatement 适合语句相同，只是参数不通的情况
	@Test
	public void test3() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("insert into t1 values (?,?)");
		for(int i=0;i<1000001;i++){
			stmt.setInt(1, i+1);
			stmt.setString(2, "aaaa"+(i+1));
			stmt.addBatch();
			if(i%1000==0){
				stmt.executeBatch();
				stmt.clearBatch();//清理缓存
			}
		}
		
		stmt.executeBatch();
		JdbcUtil.release(null, stmt, conn);
	}
}

//大数据的存取
public class LobDemo {
	/*
	 create table t2(
	 	id int,
	 	content longtext
	 );
	 */
	@Test
	public void test1() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("insert into t2 values (?,?)");
		stmt.setInt(1, 1);
		//以流的方式
		File file = new File("src/jpm.txt");
		Reader reader = new FileReader(file);
		stmt.setCharacterStream(2, reader, (int)file.length());//PreparedStatement的实现是由数据库驱动提供的
															//MySQL:setCharacterStream(int,Reader,long);根本没有实现。
															//MySQL根本不支持那么大的数据。
		stmt.executeUpdate();
		JdbcUtil.release(null, stmt, conn);
	}
	
	//取大文本数据
	@Test
	public void test2() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("select * from t2 where id=1");
		ResultSet rs = stmt.executeQuery();
		if(rs.next()){
			Reader r = rs.getCharacterStream("content");
			//内容保存D盘的1.txt文件中
			Writer w = new FileWriter("d:/1.txt");
			int len = -1;
			char c[] = new char[1024];
			while((len=r.read(c))!=-1){
				w.write(new String(c), 0, len);
			}
			r.close();
			w.close();
		}
		JdbcUtil.release(rs, stmt, conn);
	}
	
	/*
	 create table t3(
	 	id int,
	 	content longblob
	 );
	 */
	@Test
	public void test3() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("insert into t3 values (?,?)");
		stmt.setInt(1, 1);
		//以流的方式
		InputStream in = new FileInputStream("src/26.jpg");
		
		stmt.setBinaryStream(2, in, in.available());
		stmt.executeUpdate();
		JdbcUtil.release(null, stmt, conn);
	}
	@Test
	public void test4() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement stmt = conn.prepareStatement("select * from t3 where id=1");
		ResultSet rs = stmt.executeQuery();
		if(rs.next()){
			InputStream in = rs.getBinaryStream("content");
			OutputStream out = new FileOutputStream("d:/wife.jpg");
			
			int len = -1;
			byte b[] = new byte[1024];
			while((len=in.read(b))!=-1){
				out.write(b,0,len);
			}
			in.close();
			out.close();
		}
		JdbcUtil.release(null, stmt, conn);
	}
}

/*
delimiter $$

CREATE PROCEDURE demoSp(IN inputParam VARCHAR(255), INOUT inOutParam varchar(255))
BEGIN
    SELECT CONCAT(‘zyxw---‘, inputParam) into inOutParam;
END $$

delimiter ;
 */

//如何调用已经存在的存储过程
public class CallableDemo {
	@Test
	public void test1() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		CallableStatement stmt = conn.prepareCall("{call demoSp(?,?)}");
		//输入参数：设置值
		//输出参数：注册数据类型即可
		stmt.setString(1, "YY");
		stmt.registerOutParameter(2, Types.VARCHAR);
		
		stmt.execute();
		//打印执行的结果
		System.out.println(stmt.getString(2));
		JdbcUtil.release(null, stmt, conn);
	}
}

//事务控制案例
/*


create table account(
	id int primary key auto_increment,
	name varchar(40),
	money float
)character set utf8 collate utf8_general_ci;

insert into account(name,money) values(‘aaa‘,1000);
insert into account(name,money) values(‘bbb‘,1000);
insert into account(name,money) values(‘ccc‘,1000);

 */
public class TxDemo {
	@Test
	public void test1(){
		Connection conn = null;
		PreparedStatement stmt = null;
		try{
			conn = JdbcUtil.getConnection();
			conn.setAutoCommit(false);//相当于start transaction
			
			stmt = conn.prepareStatement("update account set money=money-100 where name=‘bbb‘");
			stmt.executeUpdate();
			
//			int i=1/0;
			
			stmt = conn.prepareStatement("update account set money=money+100 where name=‘aaa‘");
			stmt.executeUpdate();
			
			conn.commit();// 提交事务
		}catch(Exception e){
//			if(conn!=null){
//				try {
//					conn.rollback();
//				} catch (SQLException e1) {
//					e1.printStackTrace();
//				}
//			}
			throw new RuntimeException(e);
		}finally{
			JdbcUtil.release(null, stmt, conn);
		}
	}
}

//设置隔离级别
public class IsolationLevelDemo {
	@Test
	public void test1() throws Exception{
		Connection conn = JdbcUtil.getConnection();
		//一定要在开启事务前更改隔离级别
		conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
		conn.setAutoCommit(false);
		
//		....
		conn.commit();
	}
}