你需要什麼

• 大約15分鐘
• IntelliJ IDEA或其他編輯器
• JDK 1.8或更高版本
• Maven 3.2+

你會建立什麼

您將使用Spring的 JdbcTemplate 構建一個應用程式來訪問儲存在關係資料庫中的資料。

構建步驟

1、新增maven依賴。

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId
 
>
        </dependency>
        <!-- Spring Boot支援H2（一種記憶體中的關係資料庫引擎），並自動建立一個連線。 -->
        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
        </dependency>

2、新建POJO。

public class Customer {
    private
 
 long id;
    private String firstName, lastName;

    public Customer(long id, String firstName, String lastName) {
        this.id = id;
        this.firstName = firstName;
        this.lastName = lastName;
    }

    @Override
    public String toString() {
        return String.format(
                "Customer[id=%d, firstName='%s', lastName='%s']"
 
,
                id, firstName, lastName);
    }

    // getters & setters omitted for brevity
}

3、建表、存資料以及取資料。

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

@SpringBootApplication
public class Application implements CommandLineRunner {

    private static final Logger log = LoggerFactory.getLogger(Application.class);

    public static void main(String args[]) {
        SpringApplication.run(Application.class, args);
    }

    @Autowired
    JdbcTemplate jdbcTemplate;

    @Override
    public void run(String... strings) throws Exception {

        log.info("Creating tables");

        jdbcTemplate.execute("DROP TABLE customers IF EXISTS");
        jdbcTemplate.execute("CREATE TABLE customers(" +
                "id SERIAL, first_name VARCHAR(255), last_name VARCHAR(255))");

        // Split up the array of whole names into an array of first/last names
        List<Object[]> splitUpNames = Arrays.asList("John Woo", "Jeff Dean", "Josh Bloch", "Josh Long").stream()
                .map(name -> name.split(" ")) //將List中的字串變成字元陣列
                .collect(Collectors.toList()); //將流物件轉化為List

        // Use a Java 8 stream to print out each tuple of the list
        splitUpNames.forEach(name -> log.info(String.format("Inserting customer record for %s %s", name[0], name[1])));

        // Uses JdbcTemplate's batchUpdate operation to bulk load data
        jdbcTemplate.batchUpdate("INSERT INTO customers(first_name, last_name) VALUES (?,?)", splitUpNames);

        log.info("Querying for customer records where first_name = 'Josh':");
        //首先查詢，然後得到結果，之後遍歷
        jdbcTemplate.query(
                "SELECT id, first_name, last_name FROM customers WHERE first_name = ?", new Object[] { "Josh" },
                (rs, rowNum) -> new Customer(rs.getLong("id"), rs.getString("first_name"), rs.getString("last_name"))
        ).forEach(customer -> log.info(customer.toString()));
    }
}

• 這個Application類實現了Spring Boot的CommandLineRunner，這意味著它將在應用程式上下文載入後執行run（）方法。
• 你可以使用JdbcTemplate的execute方法來執行一些DDL。
• 對於單插入語句，JdbcTemplate的insert方法很好。但對於多個插入，最好使用batchUpdate。
• 使用 ？通過指示JDBC繫結變數來避免SQL注入攻擊的引數。

測試

整合完後直接執行main()方法就可以執行Spring程式。執行結果如下：