您的位置:首页 > 产品设计 > UI/UE

jdbc--query( new PreparedStatementCreator(){},new ResultSetExtractor<List>)

2016-09-21 08:49 483 查看
package com.yzl.dao.mysql;

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.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.dao.DataAccessException;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.PreparedStatementCreator;

import org.springframework.jdbc.core.ResultSetExtractor;

import com.yzl.dto.User;

public class TestServiceDaoJdbcTemplateImpl {
private static final Logger log = Logger.getLogger(TestServiceDaoJdbcTemplateImpl.class);

    @Autowired

    JdbcTemplate jdbcTemplate;

    public JdbcTemplate getJdbcTemplate() {

        return jdbcTemplate;

    }

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {

        this.jdbcTemplate = jdbcTemplate;

    }

    public int insertOrder(User user,String id) throws Exception {

        String sql="insert into users"

                + "(NAME, AGE)"

                + " values (?,?)";

        Object params[]=new Object[2];

        //long id=this.getSequenceNextValue("INF_BIZ_QUEUE_SEQ");

        //时间

        params[0]=user.getName();

        params[1]=user.getAge();

       int[] paramTypes = new int[]{Types.VARCHAR, Types.INTEGER};

        int rs =jdbcTemplate.update(sql, params, paramTypes);

        return rs;

    }

    @SuppressWarnings("unchecked")
public String SelectUser (){

    final String sql="select *from users ";

    jdbcTemplate.query( 

    new PreparedStatementCreator(){

    @Override
public PreparedStatement createPreparedStatement(
Connection conn) throws SQLException {
// TODO Auto-generated method stub

    return conn.prepareStatement(sql);
}

   

    },new ResultSetExtractor<List>(){

@Override
public List extractData(ResultSet rs) throws SQLException,
DataAccessException {
List result = new ArrayList();  
         while(rs.next()) {  
             Map row = new HashMap(); 
             System.out.println(rs.getInt("id"));
             System.out.println(rs.getString("name"));
             row.put(rs.getInt("id"), rs.getString("name"));  
             result.add(row); 
             System.out.println(result.get(0));
          }  
          return result;  
}

   

    });

   

    return "true";

    }

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  jdbc
相关文章推荐