bigdata_houtai/bigData/src/com/happy/dao/Impl/FirstBuffercImplDao.java

package com.happy.dao.Impl;

import com.happy.Model.FirstBufferC;
import com.happy.Model.FirstBufferT;
import com.happy.dao.FirstBuffercDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository("FirstBuffercDao")
public class FirstBuffercImplDao implements FirstBuffercDao {

    @Autowired
    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;

    public NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() {
        return namedParameterJdbcTemplate;
    }

    public void setNamedParameterJdbcTemplate(
            NamedParameterJdbcTemplate namedParameterJdbcTemplate) {
        this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
    }

    public int insertFirstBufferC(FirstBufferC firstBufferC){
        String sql = "insert into firstbufferc(dateT,dateTime,smT,smT_increase,smLt,red_count,red_increase,yellow_count,yellow_increase,green_count,green_increase) values(:dateT,:dateTime,:smT,:smT_increase,:smLt,:red_count,:red_increase,:yellow_count,:yellow_increase,:green_count,:green_increase)";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("dateT", firstBufferC.getDateT());
        sps.addValue("dateTime", firstBufferC.getDateTime());
        sps.addValue("smT", firstBufferC.getSmT());
        sps.addValue("smT_increase", firstBufferC.getSmT_increase());
        sps.addValue("smLt", firstBufferC.getSmLt());
        sps.addValue("red_count", firstBufferC.getRed_count());
        sps.addValue("red_increase", firstBufferC.getRed_increase());
        sps.addValue("yellow_count", firstBufferC.getYellow_count());
        sps.addValue("yellow_increase", firstBufferC.getYellow_increase());
        sps.addValue("green_count", firstBufferC.getGreen_count());
        sps.addValue("green_increase", firstBufferC.getGreen_increase());
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 第一道防护屏障接口------汇总
    public List<FirstBufferC> queryFirstBufferC(){
        String sql = "select * from firstbufferc where id=(select MAX(id) from firstbufferc) ";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        List<FirstBufferC> list = namedParameterJdbcTemplate.query(sql, sps,
                new BeanPropertyRowMapper<FirstBufferC>(FirstBufferC.class));
        if (list != null && list.size() > 0) {
            return list;
        }
        return null;
    }

}