Spring筆記05（Spring JDBC三種數據源和ORM框架的映射）

1.ORM框架的映射

01.JDBC連接數據庫以前的方式代碼，並給對象賦值

@Test
    /**
     * 以前的方式jdbc
     */
    public void TestJdbc(){
        /**
         * 連接數據庫的四要素
         */
        String driver="com.mysql.jdbc.Driver";
        String url="jdbc:mysql://localhost:3306/spring";
        String username="root";
        String password="666888";
        /**
         * 創建jdbc需要的api
         */
        Connection connection=null;
        PreparedStatement pst=null;
        ResultSet rs=null;



        try {
            //01加載驅動
            Class.forName(driver);
            //02獲取鏈接
            connection= DriverManager.getConnection(url, username, password);
            //03書寫sql語句
            String sql="select sid,sname,age from student where sid=?";
            //04給參數賦值
            pst=connection.prepareStatement(sql);
            pst.setInt(1,2);
            //05獲取查詢結果
            rs=pst.executeQuery();

            while(rs.next()){
                Student student=new Student();
                student.setSid(rs.getInt("sid"));
                student.setAge(rs.getInt("age"));
                student.setSname(rs.getString("sname"));
                System.out.println(student);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            try {
                rs.close();
                pst.close();
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

02.我們使用反射機制來 動態的給 Student對象賦值

 /**
     * 我們使用反射機制來 動態的給 Student對象賦值
     */
    public static void main(String[] args){
        /**
         * 連接數據庫的四要素
         */
        String driver="com.mysql.jdbc.Driver";
        String url="jdbc:mysql://localhost:3306/spring";
        String username="root";
        String password="666888";

        /**
         * 創建jdbc需要的api
         */
        Connection connection=null;
        PreparedStatement pst=null;
        ResultSet rs=null;



        //創建需要映射的實體類
        Object student=null;
        try {
            student=Class.forName("cn.pb.bean.Student").newInstance();
        } catch (Exception e) {
            e.printStackTrace();
        }


        try {
            //01.加載驅動
            Class.forName(driver);
            //02.獲取連接
            connection=DriverManager.getConnection(url,username,password);
            //03.書寫sql語句
            String sql="select sid,age,sname from student where sid=?";
            //04.給參數賦值
            pst=connection.prepareStatement(sql);
            pst.setInt(1,3);
            //05.返回結果
            rs=pst.executeQuery();

            while (rs.next()){
                //獲取元數據的結果集 元數據：描述數據的數據
                ResultSetMetaData metaData = rs.getMetaData();
                System.out.println("元數據"+metaData);
                int columnCount = metaData.getColumnCount();
                //遍歷元數據集合
                for (int i=1;i<=columnCount;i++){
                    //獲取數據庫字段的名稱
                    String columnName = metaData.getColumnName(i);
                    //獲取數據庫字段的類型  返回的類型都是大寫
                    String columnTypeName = metaData.getColumnTypeName(i);

                    /**
                     * 01.給我一個元數據的名稱
                     * 02.我去實體類中找對應的setXxx（）
                     */
                    String method = getMethod(columnName);
                    //賦值的時候根據類型
                    if(columnTypeName.equals("INT")){
                        student.getClass().getMethod(method,int.class).invoke(student,rs.getInt(columnName));
                    }else if(columnTypeName.equals("VARCHAR")){
                        student.getClass().getMethod(method,String.class).invoke(student,rs.getString(columnName));
                    }



                }

                Student stu= (Student) student;
                System.out.println(stu);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                rs.close();
                pst.close();
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }


    /**
     *  01.用戶給我一個字段名稱（數據庫中）
     *  02.我們返回一個set+字段名  （首字母大寫）
     *  @param  name 字段名稱
     *  @return   返回的set方法名稱
     */
    public static String getMethod(String name){//傳過來sid  返回 setSid

        return "set"+name.substring(0,1).toUpperCase()+name.substring(1);
    }

2.Spring的JDBC:

01.實體類代碼：

package cn.pb.bean;

/**
 * student的實體類
 */
public class Student {

    private   int sid;
    private   int age;
    private   String sname;

    public Student(int sid, int age, String sname) {
        this.sid = sid;
        this.age = age;
        this.sname = sname;
    }

    public Student(int age, String sname) {
        this.age = age;
        this.sname = sname;
    }

    public Student() {

    }

    public int getSid() {
        return sid;
    }

    public void setSid(int sid) {
        this.sid = sid;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public String getSname() {
        return sname;
    }

    public void setSname(String sname) {
        this.sname = sname;
    }

    @Override
    public String toString() {
        return "Student{" +
                "sid=" + sid +
                ", age=" + age +
                ", sname='" + sname + '\'' +
                '}';
    }
}

 

02.dao層代碼：

001.dao層代碼

package cn.pb.dao;

import cn.pb.bean.Student;

import java.util.List;

public interface StudentDao {
    int addStudent(Student student);
    int delStudent(Student student);
    int updateStudent(Student student);
    List<Student> findAllStudents();
}

 

002.daoImpl層代碼

package cn.pb.dao.impl;

import cn.pb.bean.Student;
import cn.pb.dao.StudentDao;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
/**
 * Spring 有一個類叫 JdbcDaoSupport  ===>BaseDao
 * JdbcDaoSupport有一個屬性叫JdbcTemplate
 * 在創建JdbcTemplate的時候 需要一個DataSource
 *
 * 我們只需要在配置文件中 配置數據源 即可！
 *
 */
public class StudentDaoImpl extends JdbcDaoSupport implements StudentDao {



    public int addStudent(Student student) {
        String sql="insert into student(sname,age) values(?,?)";
        return getJdbcTemplate().update(sql,student.getSname(),student.getAge());
    }

    public int delStudent(Student student) {
        String sql="delete from student where sid=?";
        return getJdbcTemplate().update(sql,student.getSid());
    }

    public int updateStudent(Student student) {
        String sql="update student set sname=?,age=? where sid=?";
        return getJdbcTemplate().update(sql,student.getSname(),student.getAge(),student.getSid());
    }
    /**
     * @return   行映射器  rowMapper
     */
    public List<Student> findAllStudents() {
        String sql="select * from student";
        return getJdbcTemplate().query(sql, new StudentRowMapper() {

        });
    }
}

行映射器代碼：

package cn.pb.dao.impl;


import cn.pb.bean.Student;
import org.springframework.jdbc.core.RowMapper;

import java.sql.ResultSet;
import java.sql.SQLException;

public class StudentRowMapper implements RowMapper<Student> {
    /**
     *
     * @param resultSet   之前叫 返回數據的結果集，是所有數據
     *                    現在 這個不是所有，是一行數據的結果集
     */
    public Student mapRow(ResultSet resultSet, int i) throws SQLException {
        Student student=new Student();
        student.setSid(resultSet.getInt("sid"));
        student.setSname(resultSet.getString("sname"));
        student.setAge(resultSet.getInt("age"));
        return student;
    }
}

 

03.service層代碼：

001.service層代碼：

package cn.pb.service;

import cn.pb.bean.Student;

import java.util.List;

public interface StudentService {
    int addStudent(Student student);
    int delStudent(Student student);
    int updateStudent(Student student);
    List<Student> findAllStudents();

}

 

002.serviceImpl層代碼

package cn.pb.service.impl;

import cn.pb.bean.Student;
import cn.pb.dao.StudentDao;
import cn.pb.service.StudentService;

import java.util.List;

public class StudentServiceImpl implements StudentService {
    private StudentDao dao;


    public int addStudent(Student student) {
        return dao.addStudent(student);
    }

    public int delStudent(Student student) {
        return dao.delStudent(student);
    }

    public int updateStudent(Student student) {
        return dao.updateStudent(student);
    }

    public List<Student> findAllStudents() {
        return dao.findAllStudents();
    }


    public StudentDao getDao() {
        return dao;
    }

    public void setDao(StudentDao dao) {
        this.dao = dao;
    }
}

 

04.連接數據庫的properties文件：jdbc.properties

jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.jdbcUrl=jdbc:mysql://localhost:3306/spring
jdbc.userName=root
jdbc.password=666888

05.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:p="http://www.springframework.org/schema/p"
       xmlns:c="http://www.springframework.org/schema/c"
       xmlns:context="http://www.springframework.org/schema/context"
       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">

    <!--01.加載jdbc.properties文件-->
    <context:property-placeholder location="classpath:jdbc.properties"/>

    <!--02.配置數據源-->
        <!--001.使用spring默認的數據源
        <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
            <property name="driverClassName" value="${jdbc.driverClass}"/>
            <property name="url" value="${jdbc.jdbcUrl}"/>
            <property name="username" value="${jdbc.userName}"/>
            <property name="password" value="${jdbc.password}"/>
        </bean>-->
        <!--002.使用c3p0數據源
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <property name="driverClass" value="${jdbc.driverClass}"/>
            <property name="jdbcUrl" value="${jdbc.jdbcUrl}"/>
            <property name="user" value="${jdbc.userName}"/>
            <property name="password" value="${jdbc.password}"/>
        </bean>-->
        <!--003.使用dbcp數據源-->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="${jdbc.driverClass}"/>
        <property name="url" value="${jdbc.jdbcUrl}"/>
        <property name="username" value="${jdbc.userName}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>
<!--03.配置dao  在StudentDaoImpl里要使用數據源-->
    <bean id="studentDaoImpl" class="cn.pb.dao.impl.StudentDaoImpl">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!--04.配置service-->
    <bean id="studentServiceImpl" class="cn.pb.service.impl.StudentServiceImpl">
        <property name="dao" ref="studentDaoImpl"/>
     </bean>
</beans>

 

06.測試代碼：

package cn.pb;

import cn.pb.bean.Student;
import cn.pb.service.StudentService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

public class TestJdbc {

    public static void main(String[] args) {
        ApplicationContext context=new
                ClassPathXmlApplicationContext("applicationContext.xml");
        StudentService service= (StudentService) context.getBean("studentServiceImpl");
        //service.addStudent(new Student(25,"xixi"));
        List<Student> list=service.findAllStudents();
        System.out.println(list);
    }
}