码迷，mamicode.com
首页 > 数据库 > 详细

springDao的jdbctemplate

时间：2019-03-28 15:36:20      阅读：111      评论：0      收藏：0      [点我收藏+]

标签：cte   manage   补丁   tor   pass   lombok   demo1   ring   art   

pom文件

 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.yujian</groupId>
    <artifactId>spring-dao-demo1</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-core</artifactId>
        <version>5.1.3.RELEASE</version>
    </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.3.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>5.1.3.RELEASE</version>
        </dependency>
        <!--spring连接jdbc-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.1.3.RELEASE</version>
        </dependency>
        <!--jdbc驱动-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.47</version>
        </dependency>
        <!--c3p0数据源，替代DBHelper的-->
        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.4</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>5.1.3.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>5.1.3.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.2</version>
        </dependency>
    </dependencies>

</project>
配置文件applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/tx" xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
<!--<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="com.mysql.jdbc.Driver"/>
    <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/school?useSSL=false"/>
    <property name="user" value="root"/>
    <property name="password" value="root"/>
</bean>-->
    <!--<context:property-placeholder location="db.properties"/>
    <context:component-scan base-package="com.yujian"/>-->
    <!--<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${driverClass}"/>
        <property name="jdbcUrl" value="${driverUrl}"/>
        <property name="user" value="${dbName}"/>
        <property name="password" value="${dbPass}"/>
    </bean>-->
    <!--<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    </bean>-->
    <!--<bean id="studentDao" class="com.yujian.dao.StudentDao">
        <property name="jdbcTemplate" ref="jdbcTemplate"/>
    </bean>-->
    <!--<bean id="studentService" class="com.yujian.service.StudentService">
        <property name="studentDao" ref="studentDao"/>
    </bean>-->
    <!--<tx:annotation-driven/>-->
</beans>
db.properties文件
driverClass=com.mysql.jdbc.Driver
driverUrl=jdbc:mysql://localhost:3306/school?useSSL=false
dbName=root
dbPass=root
如果用全注解方式，总文件为
package com.yujian.config;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.yujian.service.StudentService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import java.beans.PropertyVetoException;

@Configuration
@PropertySource("classpath:db.properties")
@ComponentScan("com.yujian")
@EnableTransactionManagement
/*必须加入上面的EnableTransactionManagement才可以使用事务全注解拦截
* 而且下面要有*/
public class MyConfig {
    @Value("${driverClass}")
    private String driverClass;
    @Value("${driverUrl}")
    private String driverUrl;
    @Value("${dbName}")
    private String dbName;
    @Value("${dbPass}")
    private String dbPass;
    @Bean
    public ComboPooledDataSource dataSource(){
        ComboPooledDataSource dataSource=new ComboPooledDataSource();
        try {
            dataSource.setPassword(dbPass);
            dataSource.setUser(dbName);
            dataSource.setJdbcUrl(driverUrl);
            dataSource.setDriverClass(driverClass);
        } catch (PropertyVetoException e) {
            e.printStackTrace();
        }
        return dataSource;
    }
    @Bean
    public JdbcTemplate jdbcTemplate(){
        JdbcTemplate jdbcTemplate=new JdbcTemplate();
        jdbcTemplate.setDataSource(dataSource());
        return jdbcTemplate;
    }
    @Bean
    public DataSourceTransactionManager getDataSourceTransactionManager(){
        DataSourceTransactionManager transactionManager=new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource());
        return transactionManager;
    }

}
Dao层的jdbc设置
package com.yujian.dao;

import com.yujian.model.ClassInfo;
import com.yujian.model.Student;
import com.yujian.util.Page;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;


@Component
public class StudentDao {
    //分组，列的子查询，临时表子查询没办法用orm（hibernate）做映射
    /*public JdbcTemplate getJdbcTemplate() {
        return jdbcTemplate;
    }

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
        @Data这个需要在setting里的plugins搜索lombok补丁下载才可以不用写getset
    }*/

    //匿名内部类
    @Autowired
    private JdbcTemplate jdbcTemplate;
    public List<Student> findListStudent(){
        String sql="select * from student s,classinfo c where c.classId=s.classId";
        List<Student> list=jdbcTemplate.query(sql,rowMapper);
        //可以这样写，下面代码可以多个用
        List<Student> students1=jdbcTemplate.query(sql,new BeanPropertyRowMapper(Student.class));
        List<Student> students=new ArrayList<Student>();
        List<Map<String,Object>> rows=jdbcTemplate.queryForList(sql);
        for (Map row:rows){
            Student student=new Student();
            student.setStuId((Integer) row.get("stuId"));
            student.setStuNmae((String) row.get("stuName"));
            student.setStuBirth((Date) row.get("stuBirth"));
            student.setStuSex((Integer) row.get("stuSex"));
            ClassInfo classInfo=new ClassInfo();
            classInfo.setClassId((Integer) row.get("classId"));
            classInfo.setClassName((String )row.get("className"));
            student.setClassInfo(classInfo);
            students.add(student);

        }
        return students;
    }
    private RowMapper<Student> rowMapper=new RowMapper<Student>() {
        public Student mapRow(ResultSet rs, int i) throws SQLException {
            Student student=new Student();
            student.setStuId(rs.getInt("stuId"));
            student.setStuNmae(rs.getString("stuName"));
            student.setStuBirth(rs.getDate("stuBirth"));
            student.setStuSex(rs.getInt("stuSex"));
            ClassInfo classInfo=new ClassInfo();
            classInfo.setClassId(rs.getInt("classId"));
            classInfo.setClassName(rs.getString("className"));
            student.setClassInfo(classInfo);
            return student;
        }
    };
    public Student findStudentById(int stuId){
        String sql="select * from student s,classinfo c where c.classId=s.classId and s.stuId=? ";
        /*Student student=jdbcTemplate.queryForObject(sql, new RowMapper<Student>() {
            public Student mapRow(ResultSet rs, int i) throws SQLException {
                Student student=new Student();
                student.setStuId(rs.getInt("stuId"));
                student.setStuNmae(rs.getString("stuName"));
                student.setStuBirth(rs.getDate("stuBirth"));
                student.setStuSex(rs.getInt("stuSex"));
                ClassInfo classInfo=new ClassInfo();
                classInfo.setClassId(rs.getInt("classId"));
                classInfo.setClassName(rs.getString("className"));
                student.setClassInfo(classInfo);
                return student;
            }
        },stuId);*/
        Object[]obj={stuId};
        Student student=jdbcTemplate.queryForObject(sql,obj, new RowMapper<Student>() {
            public Student mapRow(ResultSet rs, int i) throws SQLException {
                Student student=new Student();
                student.setStuId(rs.getInt("stuId"));
                student.setStuNmae(rs.getString("stuName"));
                student.setStuBirth(rs.getDate("stuBirth"));
                student.setStuSex(rs.getInt("stuSex"));
                ClassInfo classInfo=new ClassInfo();
                classInfo.setClassId(rs.getInt("classId"));
                classInfo.setClassName(rs.getString("className"));
                student.setClassInfo(classInfo);
                return student;
            }
        });

        return student;
    }

    public void updateStudent(Student student){
        String sql="update student set stuName=?,stuSex=?,stuBirth=?,classId=? where stuId=?";
        Object[]obj={student.getStuNmae(),student.getStuSex(),student.getStuBirth(),student.getClassInfo().getClassId(),student.getStuId()};
        jdbcTemplate.update(sql,obj);

    }
    public void insertStudent(Student student){
        String sql="insert into student(stuName, stuSex, stuBirth, classId) values " +
                "(?,?,?,?)";
        Object[] obj={student.getStuNmae(),student.getStuSex(),student.getStuBirth(),student.getClassInfo().getClassId()};
        jdbcTemplate.update(sql,obj);
    }
    public void deleteStudent(int stuId){
        String sql="delete from student where stuId=?";
        jdbcTemplate.update(sql,stuId);

    }
    public List<Student> listStudentBy(Student student){
        String sql="select * from student,classinfo where student.classId=classinfo.classId  ";
        List<Object> obj=new ArrayList<Object>();
            if(null!=student.getStuNmae()&&!"".equals(student.getStuNmae())){
                sql+=" and stuName=? ";
                obj.add(student.getStuNmae());
            }
            /*if(null!=student.getStuNmae()&&!"".equals(student.getStuNmae())){
                sql+=" and stuName=? ";
                obj.add(student.getStuNmae());
            }*/
            if(null!=student.getStuBirth()&&!"".equals(student.getStuBirth())){
                sql+=" and stuBirth=? ";
                obj.add(student.getStuBirth());
            }
            if(student.getStuSex()!=-1){
                sql+=" and stuSex=? ";
                obj.add(student.getStuSex());
            }
        List<Student>list=jdbcTemplate.query(sql,obj.toArray(),rowMapper);
        return list;
    }
    public List<Student> findStuentByParam(Map<String,String> param, Page page){
        String sql="select * from student ,classinfo where student.classId=classinfo.classId  ";
        List paramValue=new ArrayList();
        //条件子句
        if(null!=param&&param.size()>0) {
            sql += getParamValue(param, paramValue);
        }
        /*String stuName=param.get("stuName");
        if(stuName!=null&&!stuName.equals("")){
            sql+=" and stuName like ?";
            paramValue.add("%"+stuName+"%");
        }
        String stuSex=param.get("stuSex");
        if(stuSex!=null&&!stuSex.equals("")){
            sql+=" and stuSex like ?";
            paramValue.add("%"+stuSex+"%");
        }
        String stuBirth=param.get("stuBirth");
        if(stuBirth!=null&&!stuBirth.equals("")){
            sql+=" and stuBith like ?";
            paramValue.add("%"+stuName+"%");
        }*/
        //排序子句
        sql+=" order by stuId ";
        if(page!=null){
            sql+=" limit "+(page.getPageNo()-1)*page.getPageSize()+","+page.getPageSize();
        }
        System.out.println("sql:"+sql+"param:->"+paramValue);
        List<Student>list=jdbcTemplate.query(sql,paramValue.toArray(),rowMapper);
        return list;
    }
    private String getParamValue(Map<String,String> param,List paramValue){
        String sql="";
        String stuName=param.get("stuName");
        if(null!=stuName&&!"".equals(stuName)){
            sql+=" and stuname like ?";
            paramValue.add("%"+stuName+"%");
        }
        String stuSex=param.get("stuSex");
        if(null!=stuSex&&!"".equals(stuSex)){
            sql+=" and stusex=? ";
            paramValue.add(stuSex);
        }
        String stuBirth=param.get("stuBirth");
        if(null!=stuBirth&&!"".equals(stuBirth)){
            sql+=" and stubirth like ?";
            paramValue.add("%"+stuBirth+"%");
        }
        return sql;
    }
    public int findStudentRowCnt(Map<String,String> param){
        String sql="select count(*)  from student where 1=1";
        List paramValue=new ArrayList();
        if(null!=param&&param.size()>0) {
            sql += getParamValue(param, paramValue);
        }
        return jdbcTemplate.queryForObject(sql,paramValue.toArray(),Integer.class);
    }

}
测试文件
package com.yujian.test;

import com.yujian.config.MyConfig;
import com.yujian.dao.StudentDao;
import com.yujian.model.ClassInfo;
import com.yujian.model.Student;
import com.yujian.service.StudentService;
import com.yujian.util.DateFormat;
import com.yujian.util.Page;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class StudentTest {
    @Test
    public void testFindfListStudent(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
　　　　 //上面用的全注解方式，若是用配置文件用下面的
　　　　//ApplicationContext ctx=new ClassPathXmlApplicationContext("app*.xml");
　　　　//StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
 
        List<Student>list=studentDao.findListStudent();
        System.out.println(list);
        System.out.println(3+3.5);
    }
    @Test
    public void testFindfStudentById(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        Student student=studentDao.findStudentById(1);
        System.out.println(student);
    }
    @Test
    public void testInsertfStudentById(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        Student student=new Student();
        student.setStuNmae("赵四");
        student.setStuSex(1);
        DateFormat format=new DateFormat();
        String date="1997-03-30";
        student.setStuBirth(format.format(date));
        ClassInfo classInfo=new ClassInfo();
        classInfo.setClassId(1);
        student.setClassInfo(classInfo);
        studentDao.insertStudent(student);
    }
    @Test
    public void testUpdatefStudentById(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        Student student=new Student();
        student.setStuNmae("刘能");
        student.setStuSex(0);
        DateFormat format=new DateFormat();
        String date="1997-12-30";
        student.setStuBirth(format.format(date));
        ClassInfo classInfo=new ClassInfo();
        classInfo.setClassId(2);
        student.setClassInfo(classInfo);
        student.setStuId(6);
        studentDao.updateStudent(student);
    }
    @Test
    public void testDeleteStudent(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        studentDao.deleteStudent(7);
    }
    @Test
    public void testListStudentBy(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        Student student=new Student();
        /*student.setStuNmae("刘能");
        student.setStuSex(0);
        DateFormat format=new DateFormat();
        String date="1997-12-30";
        student.setStuBirth(format.format(date));
        ClassInfo classInfo=new ClassInfo();
        classInfo.setClassId(2);
        student.setClassInfo(classInfo);
        student.setStuId(6);*/
//        student.setStuNmae("李四");
//        student.setStuSex(-1);
        List<Student> students=studentDao.listStudentBy(student);
        System.out.println(students);
    }
    @Test
    public void testListStudent(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentDao studentDao=(StudentDao) ctx.getBean("studentDao");
        Map<String,String> map=new HashMap<String, String>();

        /*student.setStuNmae("刘能");
        student.setStuSex(0);
        DateFormat format=new DateFormat();
        String date="1997-12-30";
        student.setStuBirth(format.format(date));
        ClassInfo classInfo=new ClassInfo();
        classInfo.setClassId(2);
        student.setClassInfo(classInfo);
        student.setStuId(6);*/
//        map.put("stuName","李");
        /*List<Student> students=studentDao.findStuentByParam(map,null);
        System.out.println(students);*/
        int row=studentDao.findStudentRowCnt(map);

        System.out.println("row:"+row);
        Page page=new Page();
        page.setRow(row);
        page.setPageSize(3);
        System.out.println("pageCnt:"+page.getPageCnt());
        System.out.println("pageNo1:"+page.getPageNo());
        page.setPageNo(3);
        System.out.println("pageNo2:"+page.getPageNo());
        List<Student> list=studentDao.findStuentByParam(map,page);
        System.out.println(list);
    }
    @Test
    public void testInsertfStudentService(){
        ApplicationContext ctx=new AnnotationConfigApplicationContext(MyConfig.class);
        StudentService studentService=(StudentService) ctx.getBean("studentService");
        Student student=new Student();
        student.setStuNmae("刘芮玲34");
        student.setStuSex(1);
        DateFormat format=new DateFormat();
        String date="1997-03-30";
        student.setStuBirth(format.format(date));
        ClassInfo classInfo=new ClassInfo();
        classInfo.setClassId(1);
        student.setClassInfo(classInfo);
        studentService.insertStudent(student);
    }
}






 

springDao的jdbctemplate

标签：cte   manage   补丁   tor   pass   lombok   demo1   ring   art   

原文地址：https://www.cnblogs.com/pursue339/p/10615090.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！