zoukankan      html  css  js  c++  java
  • Spring JdbcTemplate 的使用与学习

    JDBCTemplate 是SPRING 框架自带的一种对sql 语句查询的封装 ,封装非常完善,虽然与Hibernate比起来有一点麻烦,但是学号JDBCTemplate可以让我们用Spirngmvc框架去代替SSH,降低了我们的学习成本。用起来也更加方便,测试代码如下,包括执行mysql 语句,分页,调用存储过程,返回对象数组,返回整数数组,返回单个对象等

    package com.tz.jdbctemplate;

    import java.sql.CallableStatement;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Types;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;

    import org.apache.struts2.json.JSONException;
    import org.apache.struts2.json.JSONUtil;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.dao.DataAccessException;
    import org.springframework.jdbc.core.CallableStatementCallback;
    import org.springframework.jdbc.core.CallableStatementCreator;
    import org.springframework.jdbc.core.CallableStatementCreatorFactory;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.core.PreparedStatementCreator;
    import org.springframework.jdbc.core.PreparedStatementSetter;
    import org.springframework.jdbc.core.RowCallbackHandler;
    import org.springframework.jdbc.core.RowMapper;
    import org.springframework.jdbc.core.SqlOutParameter;
    import org.springframework.jdbc.core.SqlParameter;
    import org.springframework.jdbc.datasource.DriverManagerDataSource;
    import org.springframework.jdbc.support.GeneratedKeyHolder;
    import org.springframework.jdbc.support.KeyHolder;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

    import com.tz.bean.User;

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations = "classpath:config/applicationContext.xml")
    public class TemplateTest {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    //明白的原理,会懂得配置,然后会懂得使用和开发,然后在深入
    @Test
    public void handle() throws SQLException{
    DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://localhost:3306/test");
    dataSource.setUsername("root");
    dataSource.setPassword("xiaoer");
    Connection connection = dataSource.getConnection();
    PreparedStatement statement = connection.prepareStatement("select * from student");
    ResultSet rs = statement.executeQuery();
    while(rs.next()){
    System.out.println(rs.getInt("id")+"==="+rs.getString("name"));
    }
    rs.close();
    statement.close();
    connection.close();
    }

    @Test
    public void handle2(){
    DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://localhost:3306/test");
    dataSource.setUsername("root");
    dataSource.setPassword("xiaoer");
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    jdbcTemplate.query("select * from student", new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    System.out.println(rs.getInt("id")+"==="+rs.getString("name"));
    }
    });
    //hibernate
    //List<Student> students = getSession().createSQLQuery("select * from student").list();
    //List<Student> students = getSession().createQuery("from student").list();
    }


    @Test
    public void handle3(){
    jdbcTemplate.query("select * from student", new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    System.out.println(rs.getInt("id")+"==="+rs.getString("name"));
    }
    });
    }

    @Test
    public void handle4(){
    ApplicationContext context = new ClassPathXmlApplicationContext("classpath:config/applicationContext.xml");
    JdbcTemplate jdbcTemplate = (JdbcTemplate) context.getBean("jdbcTemplate");
    jdbcTemplate.query("select * from student", new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    System.out.println(rs.getInt("id")+"==="+rs.getString("name"));
    }
    });
    }


    /*增加,修改,删除*/
    @Test
    public void handle5(){//几乎不用
    //新增,修改,删除---update()
    final String sql = "INSERT INTO student(name,age,male) VALUES(?,?,?)";//常量效率远远要高于普通变量
    jdbcTemplate.update(new PreparedStatementCreator() {
    @Override
    public PreparedStatement createPreparedStatement(Connection con)
    throws SQLException {
    PreparedStatement statement = con.prepareStatement(sql);
    statement.setString(1, "zhangsan");
    statement.setInt(2, 100);
    statement.setInt(3, 1);
    return statement;
    }
    });
    }

    @Test
    public void handle6(){//不建议使用
    //新增,修改,删除---update()
    final String sql = "INSERT INTO student(name,age,male) VALUES('keke',56,1)";//常量效率远远要高于普通变量
    jdbcTemplate.update(sql);
    }

    @Test
    public void handle8(){//可以使用
    final String sql = "INSERT INTO student(name,age,male) VALUES(?,?,?)";//常量效率远远要高于普通变量
    //PreparedStatementSetter 就是专门给所有sql语句(insert update select delete)带有?赋值的匿名内部类。
    jdbcTemplate.update(sql,new PreparedStatementSetter() {
    @Override
    public void setValues(PreparedStatement ps) throws SQLException {
    ps.setString(1, "kekexxx");
    ps.setInt(2, 587);
    ps.setInt(3, 0);
    }
    });
    }

    @Test
    public void handle7(){//经常使用
    //新增,修改,删除---update()
    final String sql = "INSERT INTO student(name,age,male) VALUES(?,?,?)";//常量效率远远要高于普通变量
    jdbcTemplate.update(sql,"xxxxx",686,0);
    }

    @Test
    public void handle9(){//经常使用
    final String sql = "INSERT INTO student(name,age,male) VALUES(?,?,?)";//常量效率远远要高于普通变量
    Object[] params = {"mark", 16,1};
    jdbcTemplate.update(sql,params,new int[]{Types.VARCHAR,Types.INTEGER,Types.INTEGER});
    //jdbcTemplate.update(sql, new Object[]{"mark", 16,1},new int[]{Types.VARCHAR,Types.INTEGER,Types.INTEGER});
    }

    //在新增的时候有时候需要返回主键
    @Test
    public void handle10(){
    final String sql = "INSERT INTO student(name,age,male) VALUES(?,?,?)";//常量效率远远要高于普通变量
    KeyHolder keyHolder = new GeneratedKeyHolder();
    jdbcTemplate.update(new PreparedStatementCreator() {
    @Override
    public PreparedStatement createPreparedStatement(Connection con)
    throws SQLException {
    PreparedStatement statement = con.prepareStatement(sql);
    statement.setString(1, "zhangsan");
    statement.setInt(2, 100);
    statement.setInt(3, 1);
    return statement;
    }
    }, keyHolder);
    //返回你新增的主键
    int key = keyHolder.getKey().intValue();
    System.out.println("我添加的数据返回的主键是:======"+key);
    }


    @Test
    public void handle11(){//经常使用
    //新增,修改,删除---update()
    final String sql = "UPDATE student SET `name`=?,age=? WHERE name=?";//常量效率远远要高于普通变量
    jdbcTemplate.update(sql,"xiaoer",10,"小丑");
    }

    @Test
    public void handle12(){//经常使用
    //新增,修改,删除---update()
    final String sql = "delete from student where id = ?";//常量效率远远要高于普通变量
    jdbcTemplate.update(sql,7);
    }



    /*
    * *************************************查询*******************************
    * RowCallbackHandler:无返回值,在大数据量处理的一定使用RowCallbackHandler
    * RowMapper:这个返回的是一个集合.
    * 给所有的用户(100)用户发一条短信,RowCallbackHandler
    * RowMapper---100万集合中--在发送
    *
    * jdbcTemplate.query(psc, rch);
    * jdbcTemplate.query(sql, rch);
    * jdbcTemplate.query(sql, pss, rch);
    *
    * 下面这三个是常用的
    * jdbcTemplate.query(sql, rch, args);
    * jdbcTemplate.query(sql, args, rch);
    * jdbcTemplate.query(sql, args, argTypes, rch);
    *
    */
    @Test
    public void handle13(){//不常用
    //oracle sqlservler mysql:查询表中所有的数据的时候,数据库服务器并不会把所有的数据都都放内存中,而在通过里面数据服务器里面的默认因子去装载到内存中
    //oracle ==10---io()
    final String sql = "select * from student where male = ?";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(new PreparedStatementCreator() {
    @Override
    public PreparedStatement createPreparedStatement(Connection con)
    throws SQLException {
    PreparedStatement statement = con.prepareStatement(sql);
    statement.setInt(1, 0);
    return statement;
    }
    }, new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }


    @Test
    public void handle14(){//可能会使用,不建议
    final String sql = "select * from student where male = 0";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }


    @Test
    public void handle16(){//可以使用,不推荐
    final String sql = "select * from student where male = ?";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new PreparedStatementSetter() {
    @Override
    public void setValues(PreparedStatement ps) throws SQLException {
    ps.setInt(1, 0);
    }
    },new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }



    @Test
    public void handle17(){//经常使用,推荐
    final String sql = "select * from student where male = ?";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new Object[]{0},new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }


    @Test
    public void handle18(){//经常使用,推荐
    final String sql = "select * from student where male = ? ";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    },0);

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }


    @Test
    public void handle19(){//经常使用,推荐
    final String sql = "select * from student where male = ? and age > ?";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new Object[]{0,20},new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }

    @Test
    public void handle21(){//经常使用,不推荐
    final String sql = "select * from student where male = ? and age > ?";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new Object[]{0,20},new int[]{Types.INTEGER,Types.INTEGER},new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }


    @Test
    public void handle20(){//经常使用,推荐
    final String sql = "select * from student where male = ? and age > ? ";
    final List<User> users = new ArrayList<User>();
    jdbcTemplate.query(sql,new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    users.add(user);
    }
    },0,20);

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }




    /**
    *
    * RowMapper---100万集合中--在发送
    *
    * <T> List<T> jdbcTemplate.query(psc, rowMapper);
    * <T> List<T>jdbcTemplate.query(sql, rowMapper);
    * <T> List<T>jdbcTemplate.query(sql, pss, rowMapper);
    *
    * 下面这三个是常用的
    * <T> List<T>jdbcTemplate.query(sql, rowMapper, args);
    * <T> List<T>jdbcTemplate.query(sql, args, rowMapper);
    * <T> List<T>jdbcTemplate.query(sql, args, argTypes, rowMapper);
    */
    @Test
    public void handle22(){//经常使用,推荐
    final String sql = "select * from student where male = ? and age > ? ";
    List<User> users = jdbcTemplate.query(sql,new RowMapper<User>() {
    @Override
    public User mapRow(ResultSet rs, int index) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    return user;
    }
    },0,20);

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }

    @Test
    public void handle23(){//经常使用,推荐
    final String sql = "select * from student where male = ? and age > ? ";
    List<User> users = jdbcTemplate.query(sql,new Object[]{0,20},new RowMapper<User>() {
    @Override
    public User mapRow(ResultSet rs, int index) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    return user;
    }
    });

    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }
    }

    //当个实体对象返回
    @Test
    public void handle24(){//经常使用,推荐
    final String sql = "select * from student where id = ? ";
    User user = jdbcTemplate.query(sql,new Object[]{8},new RowMapper<User>() {
    @Override
    public User mapRow(ResultSet rs, int index) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    return user;
    }
    }).get(0);
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }

    @Test
    public void handle25(){//经常使用,推荐
    final String sql = "select * from student where id = ? ";
    final User user = new User();
    jdbcTemplate.query(sql,new Object[]{8},new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    }
    });
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }


    @Test
    public void hanle26(){
    final String sql = "select * from student where id = ? ";
    User user = jdbcTemplate.queryForObject(sql, new RowMapper<User>() {
    @Override
    public User mapRow(ResultSet rs, int rowNum) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    return user;
    }
    },8);
    System.out.println(sql);
    System.out.println(user.getUserId()+"==="+user.getUsername()+"==="+user.getAge());
    }


    @Test
    public void hanle27(){
    final String sql = "select * from student where id = ? ";
    Map<String, Object> map = jdbcTemplate.queryForMap(sql,8);
    System.out.println(map);
    }


    //求总数(把常用的聚合函数sum,max,avg,自己去实现一次,日期,截取,替换这些常用sql要去总结和归纳)
    @Test
    public void handle28(){
    final String sql = "SELECT count(1) from student";
    jdbcTemplate.query(sql, new RowCallbackHandler() {
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    System.out.println(rs.getInt(1));
    }
    });
    }



    @Test
    public void test2(){
    sayHello("Nio","BUKENG","robinName");
    }

    public void sayHello(String ...names){
    for (String string : names) {
    System.out.println(string);
    }
    }


    /**
    * int queryForInt(sql)
    * int queryForInt(sql,Object...args)
    * int queryForInt(sql,Object[] params,int[] types)
    *
    */
    @Test
    public void handle29(){
    //第一种方式
    //final String sql = "SELECT count(1) from student where age > 30 && male = 1";
    //int count = jdbcTemplate.queryForInt(sql);
    final String sql = "SELECT count(1) from student where age > ? && male = ?";
    int count =jdbcTemplate.queryForInt(sql,30,1);
    System.out.println("count=============="+count);
    int count2 = jdbcTemplate.queryForInt(sql, new Object[]{30,1},new int[]{Types.INTEGER,Types.INTEGER});
    System.out.println("count2=============="+count2);
    }


    @Test
    public void handle30(){
    final String sql = "SELECT count(1) from student where age > ? && male = ?";
    Integer count = jdbcTemplate.queryForObject(sql, new Object[]{30,1},new RowMapper<Integer>(){
    @Override
    public Integer mapRow(ResultSet rs, int rowNum) throws SQLException {
    return rs.getInt(1);
    }
    });
    System.out.println("================"+count);
    }

    //求年龄大于30岁的总数和综合,和平均数
    @Test
    public void handle31(){
    final String sql = "SELECT sum(age) as s,count(1) as c ,avg(age) from student where age > ? && male = ?";
    Map<String, Object> map = jdbcTemplate.queryForObject(sql, new Object[]{30,1},new RowMapper<Map<String, Object>>(){
    @Override
    public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put("sum", rs.getInt(1));
    map.put("count", rs.getInt(2));
    map.put("avg", rs.getInt(3));
    return map;
    }
    });
    System.out.println("================"+map);
    }


    @Test
    public void handle32(){
    final String sql = "SELECT sum(age) as s,count(1) as c ,avg(age) from student where age > ? && male = ?";
    Integer[] integers = jdbcTemplate.queryForObject(sql, new Object[]{30,1},new RowMapper<Integer[]>(){
    @Override
    public Integer[] mapRow(ResultSet rs, int rowNum) throws SQLException {
    Integer[] integers = new Integer[3];
    integers[0] = rs.getInt(1);
    integers[1] = rs.getInt(2);
    integers[2] = rs.getInt(3);
    return integers;
    }
    });
    for (Integer integer : integers) {
    System.out.println("================"+integer);
    }
    }

    @Test
    public void handle33(){
    final String sql = "SELECT sum(age) as s,count(1) as c ,avg(age) from student where age > ? && male = ?";
    Count count= jdbcTemplate.queryForObject(sql, new Object[]{30,1},new RowMapper<Count>(){
    @Override
    public Count mapRow(ResultSet rs, int rowNum) throws SQLException {
    Count count = new Count();
    count.setSum(rs.getInt(1));
    count.setCount(rs.getInt(2));
    count.setAvg(rs.getInt(3));
    return count;
    }
    });
    System.out.println("================"+count.getSum());
    System.out.println("================"+count.getCount());
    System.out.println("================"+count.getAvg());
    }

    @Test
    public void handle34() throws JSONException{
    List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from student");
    System.out.println(maps);
    //struts2 -json-lib.jar --xwork.jar
    String jsonString = JSONUtil.serialize(maps, null, null, false, true);
    System.out.println(jsonString);
    //[{id=1, name=单晨, age=17, male=1, createtime=2014-10-19 20:39:04.0, updatetime=null}, {id=2, name=keke, age=30, male=1, createtime=2014-10-19 20:39:25.0, updatetime=null}, {id=3, name=赵龙, age=22, male=1, createtime=2014-10-19 20:39:25.0, updatetime=null}, {id=4, name=白羊, age=21, male=0, createtime=2014-10-19 20:39:46.0, updatetime=null}, {id=6, name=xiaoer, age=10, male=0, createtime=2014-10-19 20:40:28.0, updatetime=null}, {id=8, name=keke, age=21, male=1, createtime=2015-02-26 23:40:33.0, updatetime=null}, {id=9, name=fei, age=1, male=1, createtime=2015-02-26 23:42:03.0, updatetime=null}, {id=10, name=zhangsan, age=100, male=1, createtime=2015-02-26 23:45:17.0, updatetime=null}, {id=11, name=keke, age=56, male=1, createtime=2015-02-26 23:46:37.0, updatetime=null}, {id=12, name=xxxxx, age=686, male=0, createtime=2015-02-26 23:47:59.0, updatetime=null}, {id=13, name=kekexxx, age=587, male=0, createtime=2015-02-26 23:53:27.0, updatetime=null}, {id=14, name=mark, age=16, male=1, createtime=2015-02-26 23:55:58.0, updatetime=null}, {id=15, name=mark, age=16, male=1, createtime=2015-02-26 23:57:47.0, updatetime=null}, {id=16, name=zhangsan, age=100, male=1, createtime=2015-02-27 00:01:26.0, updatetime=null}]
    //[{"id":1,"name":"单晨","age":17,"male":1,"createtime":"2014-10-19T20:39:04"},{"id":2,"name":"keke","age":30,"male":1,"createtime":"2014-10-19T20:39:25"},{"id":3,"name":"赵龙","age":22,"male":1,"createtime":"2014-10-19T20:39:25"},{"id":4,"name":"白羊","age":21,"male":0,"createtime":"2014-10-19T20:39:46"},{"id":6,"name":"xiaoer","age":10,"male":0,"createtime":"2014-10-19T20:40:28"},{"id":8,"name":"keke","age":21,"male":1,"createtime":"2015-02-26T23:40:33"},{"id":9,"name":"fei","age":1,"male":1,"createtime":"2015-02-26T23:42:03"},{"id":10,"name":"zhangsan","age":100,"male":1,"createtime":"2015-02-26T23:45:17"},{"id":11,"name":"keke","age":56,"male":1,"createtime":"2015-02-26T23:46:37"},{"id":12,"name":"xxxxx","age":686,"male":0,"createtime":"2015-02-26T23:47:59"},{"id":13,"name":"kekexxx","age":587,"male":0,"createtime":"2015-02-26T23:53:27"},{"id":14,"name":"mark","age":16,"male":1,"createtime":"2015-02-26T23:55:58"},{"id":15,"name":"mark","age":16,"male":1,"createtime":"2015-02-26T23:57:47"},{"id":16,"name":"zhangsan","age":100,"male":1,"createtime":"2015-02-27T00:01:26"}]
    }

    @Test
    //错误
    public void handle35() throws JSONException{
    //如果要想支持的话,那么久和hibernate一样了。
    List<Student> students = jdbcTemplate.queryForList("select * from student", Student.class);
    String jsonString = JSONUtil.serialize(students, null, null, false, true);
    System.out.println(jsonString);

    }

    @Test
    public void handle36(){
    //execute:动态创建数据库,表,索引,alert 存储过程,函数,触发器
    jdbcTemplate.execute("create database keke");
    }


    //批量处理(修改,删除,新增)为了解决大数量的导入和导出的时候,一些大批量量数据的的发送,100万发一条的短信

    @Test
    public void hanler37(){
    jdbcTemplate.query("select * from student",new RowCallbackHandler(){
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    //给学生发送短信
    }
    });
    }

    @Test
    public void hanler38(){
    //我要把所有的学生的名称加上一个前缀tz
    final List<Student> students = new ArrayList<Student>();
    jdbcTemplate.query("select * from student",new RowCallbackHandler(){
    @Override
    public void processRow(ResultSet rs) throws SQLException {
    //给学生发送短信
    Student student = new Student();
    student.setId(rs.getInt("id"));
    student.setName(rs.getString("name"));
    students.add(student);
    }
    });

    //如果牵涉到update 删除的时候一定要非常的谨慎条件十分满足。
    //所有的数据删除一定要逻辑删除,而且数据库一定要每天必须一定要备份.
    //服务器的IO瓶颈,
    // for (Student student : students) {
    // jdbcTemplate.update("update student set name=? where id = ?","tz"+student.getName(),student.getId());
    // }

    //第一种写法
    // jdbcTemplate.batchUpdate("update student set name=? where id = ?", new BatchPreparedStatementSetter() {
    // @Override
    // public void setValues(PreparedStatement ps, int index) throws SQLException {
    // Student student = students.get(index);
    // ps.setString(1, student.getName());
    // ps.setInt(2, student.getId());
    // }
    //
    // @Override
    // public int getBatchSize() {
    // return students.size();
    // }
    // });

    //第二种写法
    List<Object[]> objects = new ArrayList<Object[]>();
    for (Student student : students) {
    Object[] object = {student.getName()+"我爱你们",student.getId()};
    objects.add(object);
    }

    jdbcTemplate.batchUpdate("update student set name=? where id = ?", objects);
    }

    //调用存储过程(单条记录和多条记录)

    @Test
    public void handle39(){
    List<SqlParameter> sqlParameters = new ArrayList<SqlParameter>();
    Map<String, Object> map = jdbcTemplate.call(new CallableStatementCreator() {
    @Override
    public CallableStatement createCallableStatement(Connection con)
    throws SQLException {
    CallableStatement statement = con.prepareCall("{call keke()}");
    // ResultSet rs = statement.executeQuery();
    // while(rs.next()){
    //
    // }
    return statement;
    }
    }, sqlParameters);

    System.out.println(map.get("#result-set-1"));
    }


    @Test
    public void handle40(){
    List<SqlParameter> sqlParameters = new ArrayList<SqlParameter>();
    final List<Student> students = new ArrayList<Student>();
    jdbcTemplate.call(new CallableStatementCreator() {
    @Override
    public CallableStatement createCallableStatement(Connection con)
    throws SQLException {
    CallableStatement statement = con.prepareCall("{call keke()}");
    ResultSet rs = statement.executeQuery();
    Student student = null;
    while(rs.next()){
    student= new Student();
    student.setId(rs.getInt("id"));
    student.setName(rs.getString("name"));
    students.add(student);
    }
    return statement;
    }
    }, sqlParameters);

    for (Student student : students) {
    System.out.println(student.getId()+"==="+student.getName());
    }
    }


    @Test
    public void hanle41(){
    List<SqlParameter> sqlParameters = new ArrayList<SqlParameter>();
    sqlParameters.add(new SqlParameter("cage", Types.INTEGER));
    sqlParameters.add(new SqlOutParameter("number", Types.INTEGER));
    sqlParameters.add(new SqlOutParameter("name", Types.VARCHAR));
    Map<String, Object> map = jdbcTemplate.call(new CallableStatementCreator() {
    @Override
    public CallableStatement createCallableStatement(Connection con)
    throws SQLException {
    CallableStatement statement = con.prepareCall("{call USER_RELATIONS(?,?,?)}");
    statement.setInt(1, 17);
    return statement;
    }
    }, sqlParameters);

    System.out.println(map.get("number"));
    System.out.println(map.get("name"));
    }

    @Test
    public void hanle42(){
    CallableStatementCreatorFactory factory = new CallableStatementCreatorFactory("{call USER_RELATIONS(?,?,?)}");
    factory.addParameter(new SqlParameter("cage", Types.INTEGER));
    factory.addParameter(new SqlOutParameter("number", Types.INTEGER));
    factory.addParameter(new SqlOutParameter("name", Types.VARCHAR));
    Map<String,Integer> params = new HashMap<String, Integer>();
    params.put("cage", 17);
    CallableStatementCreator creator = factory.newCallableStatementCreator(params);
    //====================================【出异常了哦!!!!】CallableStatementCallback; SQL [{call USER_RELATIONS(?,?,?)}]; Parameter number 1 is not an OUT parameter; nested exception is java.sql.SQLException: Parameter number 1 is not an OUT parameter
    jdbcTemplate.execute(creator,new CallableStatementCallback<Map<String, Object>>() {
    @Override
    public Map<String, Object> doInCallableStatement(
    CallableStatement cs) throws SQLException,
    DataAccessException {
    cs.execute();
    Map<String,Object> map = new HashMap<String, Object>();
    System.out.println(cs.getInt(2)+"========="+cs.getString(3));
    return map;
    }
    });


    }

    //分页

    @Test
    public void hanle43(){
    List<User> users = findUsers("578789",10, 10);
    for (User user : users) {
    System.out.println(user.getUserId()+"==="+user.getUsername());
    }
    }

    public List<User> findUsers(String password,int pageNo,int pageSize){
    String sql = "select * from user where 1=1 ";
    String countSql ="select count(1) from user where 1=1 ";
    if(password!=null){
    sql+=" and password = '"+password+"'";
    countSql+=" and password = '"+password+"' ";
    }
    System.out.println(countSql);
    List<User> users = jdbcTemplate.query(sql+" limit ?,?", new RowMapper<User>(){
    @Override
    public User mapRow(ResultSet rs, int index) throws SQLException {
    User user = new User();
    user.setUserId(rs.getInt("id"));
    user.setUsername(rs.getString("username"));
    return user;
    }
    },pageNo,pageSize);

    Integer totalCount = jdbcTemplate.queryForObject(countSql,Integer.class);
    System.out.println("总页数是:"+totalCount);
    return users;
    }



    }

  • 相关阅读:
    在线|九月月考选填题
    函数$f(x)=e^xpm e^{-x}$相关
    偶函数性质的推广
    2020年全国卷Ⅱ卷文科数学选填题解析版
    2020年全国卷Ⅱ卷文科数学解答题解析版
    待定系数法
    特殊方法求函数解析式
    phd文献阅读日志-4.1
    phd文献阅读日志-1.2~3.2(1.2,2.1,2.2,3.1,3.2)
    完美解决linux下vim在终端不能用鼠标复制的问题
  • 原文地址:https://www.cnblogs.com/zengda/p/4331892.html
Copyright © 2011-2022 走看看