Spring連接數據庫的實現

數據庫連接JDBC

JDBC（Java Data Base Connectivity，Java數據庫連接）是一種用於執行SQL語句的JavaAPI，可以為多種關系數據庫提供統一訪問，它由一組用Java語言編寫的類和接口組成。JDBC為數據庫開發人員提供了一個標准的API，據此可以構建更高級的工具和接口，使數據庫開發人員能夠用純JavaAPI編寫數據庫應用程序，並且可跨平台運行，並且不受數據庫供應商的限制。

JDBC連接數據庫的流程及其原理如下：

（1）在開發環境中加載指定數據庫的驅動程序。不如你使用的是MySQL，那么需要去下載MySQL支持JDBC的驅動程序（mysql-connector-java-5.1.18-bin.jar）。

（2）在Java程序中加載驅動程序。在Java程序中，可以通過“Class.forName("指定數據庫的驅動程序")”的方式來加載添加到開發環境中的驅動程序，例如加載MySQL的數據驅動程序的代碼為Class.forName("com.mysql.jdbc.Driver")。

（3）創建數據連接對象。通過DriverManager類創建數據庫連接對象Connection。DriverManager類作用於Java程序和JDBC驅動程序之間，用於檢查所加載的驅動程序是否可以建立連接，然后通過它的getConnection方法根據數據庫的URL、用戶名和密碼，創建一個JDBC Connection對象，例如：Connection connection = DriverManager.getConnection("連接數據庫的URL","用戶名","密碼")。其中URL = 協議名 + IP地址（域名）+端口+數據庫名稱；用戶名和密碼是指登錄數據庫所使用的用戶名和密碼。

（4）創建Statement對象。Statement類的主要是用於執行靜態SQL語句並返回它所生成結果的對象。通過Connection對象的createStatement()方法可以創建一個Statement對象。例如：Statement statement = connection.createStatement()。

（5）調用Statement對象的相關方法執行相對應的SQL語句。通過execuUpdate方法來對數據更新，包括插入和刪除等操作；通過調用Statement對象的executeQuery方法進行數據的查詢，而查詢的結果會得到ResultSet對象，ResultSet表示執行查詢數據庫返回的數據的集合，ResultSet對象具有可以指向當前數據行的指針。通過該對象的next方法，使得指針指向下一行，然后將數據以列號或者字段名取出，如果next方法返回null，則表示下一行中沒有數據存在。

（6）關閉數據庫連接。使用完數據庫或者不需要訪問數據庫時，通過Connection的close方法及時關閉數據庫連接。

Spring連接數據庫程序實現

 Spring中的JDBC連接與直接使用JDBC去連接還是有所差別的，Spring對JDBC做了大量封裝，消除了冗余代碼，使得開發量大大減少。下面舉個例子簡單認識Spring中的JDBC操作。

（1）創建數據表結構。

CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  `sex` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

 （2）創建對應數據表的PO。

public class User {

    private int id;
    private String name;
    private  int age;
    private String sex;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

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

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }
}

（3）創建表與實體之間的映射。

public class UserRowMapper implements RowMapper {

    public Object mapRow(ResultSet resultSet, int i) throws SQLException {
        User user = new User();
        user.setId(resultSet.getInt("id"));
        user.setName(resultSet.getString("name"));
        user.setAge(resultSet.getInt("age"));
        user.setSex(resultSet.getString("sex"));

        return user;
    }

    @Override
    public int[] getRowsForPaths(TreePath[] path) {
        return new int[0];
    }
}

（4）創建數據操作接口。

public interface UserService {

    public void save(User user);

    public List<User> getUser();
}

（5）創建數據操作接口實現類。

public class UserServiceImpl implements UserService {

    private JdbcTemplate jdbcTemplate;
    //設置數據源
    public void setDataSource(DataSource dataSource){
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }

    @Override
    public void save(User user) {
        jdbcTemplate.update("insert into USER(name ,age,sex) values (?,?,?)",new Object[]{user.getName(),user.getAge(),user.getSex()},
                new int[]{Types.VARCHAR,Types.INTEGER,Types.VARCHAR});

    }

    @Override
    public List<User> getUser() {
        List<User> list = jdbcTemplate.query("select * from user",new UserRowMapper());
        return list;
    }
}

（6）創建Spring配置文件。（PS：需要導入c3p0-0.9.1.jar、commons-dbcp-1.4.jar、commons-pool-1.6.jar3個包，版本非固定）

<!--配置數據源 -->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" >
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/my_spring"/>
        <property name="username" value="yhl"/>
        <property name="password" value="1234"/>
        <property name="initialSize" value="5"/>
        <property name="maxIdle" value="2"/>
        <property name="maxTotal" value="10"/>
    </bean>
    <bean id="userService" class="com.joe.mytag.jdbc.UserServiceImpl">
        <property name="dataSource" ref="dataSource"/>
    </bean>

（7）測試。

public static void main(String[] args) {
       ApplicationContext acp = new ClassPathXmlApplicationContext("spring.xml");
       UserService userService = (UserService) acp.getBean("userService");
       User user = new User();
       user.setName("Joe");
       user.setSex("男");
       user.setAge(25);
       userService.save(user);
       List<User> person = userService.getUser();
       for (User us : person){
           System.out.println(us.getName()+us.getAge() + us.getSex());
       }
    }

運行結果：

Joe25男

 參考：《Spring源碼深度解析》 郝佳 編著：