/**

* 获取自增长值

* @author APPle

*/

public class Demo1 {

@Test

public void test(){

//插入部门表数据

String deptSql = "INSERT INTO dept(deptName) VALUES(?)";

//插入员工表数据

String empSql = "INSERT INTO employee(empName,deptId) VALUES(?,?)";

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

/**

* 1）插入部门

*/

//预编译部门sql

//stmt = conn.prepareStatement(deptSql);

//

/**

* 1.1 使用两个参数的prepareStatement（）方法，指定可以返回自动增长的键值

* Statement.RETURN_GENERATED_KEYS: 可以返回自动增长值

* Statement.NO_GENERATED_KEYS: 不能返回自动增长值

*/

stmt = conn.prepareStatement(deptSql, Statement.RETURN_GENERATED_KEYS);

//设置参数

stmt.setString(1, "秘书部");

//执行部门sql

stmt.executeUpdate();

/**

* 1.2 获取自增长的值

*/

rs = stmt.getGeneratedKeys();

Integer deptId = null;

if(rs.next()){

deptId = rs.getInt(1);//得到第一行第一列的值

}

/**

* 2)插入员工，员工在刚添加的部门中

*/

stmt = conn.prepareStatement(empSql);

//设置参数

stmt.setString(1, "李四");

stmt.setInt(2, deptId); //如何获取刚刚添加的部门ID？？

//执行员工sql

stmt.executeUpdate();

}catch(Exception e){

e.printStackTrace();

}finally{

JdbcUtil.close(conn, stmt, rs);

}

}

}

/**

* 对大文本数据处理

* @author APPle

*/

public class Demo1 {

/**

* 文件保存到数据中

*/

@Test

public void testWrite(){

Connection conn = null;

PreparedStatement stmt = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

//创建PreparedStatement

String sql = "INSERT INTO test1(content) VALUES(?)";

stmt =conn.prepareStatement(sql);

//设置参数

/**

* 参数一： 参数位置

* 参数二： 输入字符流

*/

/**

* 读取本地文件，返回输入字符流

*/

FileReader reader = new FileReader(new File("e:/Demo1.java"));

stmt.setClob(1, reader);

//执行sql

int count = stmt.executeUpdate();

System.out.println("影响了"+count+"行");

}catch(Exception e){

e.printStackTrace();

}finally{

JdbcUtil.close(conn, stmt, null);

}

}

/**

* 从数据中读取文本内容

*/

@Test

public void testRead(){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

String sql = "SELECT * FROM test1 where id=?";

stmt = conn.prepareStatement(sql);

//设置参数

stmt.setInt(1, 2);

//执行sql,返回结果集

rs = stmt.executeQuery();

if(rs.next()){

//方式一：当做字符串取出数据

/*

String content = rs.getString("content");

System.out.println(content);

*/

//方式二：返回输入流形式

Clob clob = rs.getClob("content");

Reader reader = clob.getCharacterStream();

//写出到文件中

FileWriter writer = new FileWriter(new File("e:/Demo2.java"));

char[] buf = new char[1024];

int len = 0;

while( (len=reader.read(buf))!=-1){

writer.write(buf, 0, len);

}

//关闭流

writer.close();

reader.close();

}

}catch(Exception e){

e.printStackTrace();

}finally{

JdbcUtil.close(conn, stmt, rs);

}

}

}

/**

* 对字节文件处理

* @author APPle

*/

public class Demo2 {

/**

* 文件保存到数据库中

*/

@Test

public void testWrite(){

Connection conn = null;

PreparedStatement stmt = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

String sql = "insert into test2(content) values(?)";

stmt = conn.prepareStatement(sql);

//设置参数

/**

* 参数一：参数位置

* 参数二:输入字节流

*/

/**

* 读取本地文件

*/

InputStream in = new FileInputStream(new File("e:/abc.wmv"));

//stmt.setBlob(1, in);

stmt.setBinaryStream(1, in);

//执行

stmt.executeUpdate();

}catch(Exception e){

e.printStackTrace();

}finally{

JdbcUtil.close(conn, stmt, null);

}

}

/**

* 注意： mysql数据库默认情况下，只能存储不超过1m的文件，由于max_allowed_packet变量的限制

* 可以修改： %mysql%/my.ini文件, 修改或添加max_allowed_packet变量，然后重启mysql即可！！

*/

/**

* 从数据中读取字节内容

*/

@Test

public void testRead(){

Connection conn = null;

PreparedStatement stmt = null;

ResultSet rs = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

String sql = "SELECT * FROM test2 where id=?";

//获取PreparedStatement

stmt = conn.prepareStatement(sql);

//设置参数

stmt.setInt(1, 1);

//执行sql

rs = stmt.executeQuery();

if(rs.next()){

//返回输入流

//InputStream in = rs.getBinaryStream("content");

InputStream in = rs.getBlob("content").getBinaryStream();

//写出文件中

FileOutputStream out = new FileOutputStream(new File("e://3.jpg"));

byte[] buf = new byte[1024];

int len = 0;

while((len=in.read(buf))!=-1){

out.write(buf, 0, len);

}

//关闭流

out.close();

in.close();

}

}catch(Exception e){

e.printStackTrace();

}finally{

JdbcUtil.close(conn, stmt, rs);

}

}

}

/**

* 模拟银行转账

* @author APPle

*/

public class Demo1 {

/**

* 从eric的账户转2000元到rose的账户上

*/

@Test

public void testTransfer(){

//从eric账户上扣除2000元

String delSql = "UPDATE account SET BALANCE=BALANCE-2000 WHERE NAME='eric'";

//向rose账户打入2000元

String addSql = "UPDATE account SET BALANCE=BALANCE+2000 WHERE NAME='rose'";

Connection conn = null;

PreparedStatement stmt = null;

try{

//获取连接

conn = JdbcUtil.getConnection();

//开启事务

conn.setAutoCommit(false); // 等价于set autocommit=0;

//预编译delSQL

stmt = conn.prepareStatement(delSql);

//执行delSQL

stmt.executeUpdate();

//发生异常

int i = 100/0;

//预编译addSql

stmt = conn.prepareStatement(addSql);

//执行addSql

stmt.executeUpdate();

//提交事务

conn.commit();// 等价于commit;

}catch(Exception e){

e.printStackTrace();

//回滚事务

try {

conn.rollback(); // 等价于rollback;

} catch (SQLException e1) {

e1.printStackTrace();

}

}finally{

JdbcUtil.close(conn, stmt, null);

}

}

}