<noframes id="bhrfl"><address id="bhrfl"></address>

    <address id="bhrfl"></address>

    <noframes id="bhrfl"><address id="bhrfl"><th id="bhrfl"></th></address>

    <form id="bhrfl"><th id="bhrfl"><progress id="bhrfl"></progress></th></form>

    <em id="bhrfl"><span id="bhrfl"></span></em>

    全部
    常見問題
    產品動態
    精選推薦

    使用JdbcTemplate訪問MySQL數據庫

    管理 管理 編輯 刪除

    對于信息的存儲,現在有非常多的產品可以選擇,其中不乏許多非常優秀的開源免費產品,比如:MySQL,Redis等。那么,在使用Spring Boot開發服務端程序時,如何實現對各流行數據存儲產品的增刪改查操作呢?

    今天我們將從最為常用的關系型數據庫開始。通過一個簡單例子,學習在Spring Boot中最基本的數據訪問工具:JdbcTemplate。

    數據源配置

    在我們訪問數據庫的時候,需要先配置一個數據源,下面分別介紹一下幾種不同的數據庫配置方式。

    首先,為了連接數據庫需要引入jdbc支持,在pom.xml中引入如下配置:

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    

    嵌入式數據庫支持

    嵌入式數據庫通常用于開發和測試環境,不推薦用于生產環境。Spring Boot提供自動配置的嵌入式數據庫有H2、HSQL、Derby,你不需要提供任何連接配置就能使用。

    比如,我們可以在pom.xml中引入如下配置使用HSQL

    <dependency>
        <groupId>org.hsqldb</groupId>
        <artifactId>hsqldb</artifactId>
        <scope>runtime</scope>
    </dependency>
    

    連接生產數據源

    以MySQL數據庫為例,先引入MySQL連接的依賴包,在pom.xml中加入:

    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    

    src/main/resources/application.properties中配置數據源信息

    spring.datasource.url=jdbc:mysql://localhost:3306/test
    spring.datasource.username=dbuser
    spring.datasource.password=dbpass
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    

    注意:因為Spring Boot 2.1.x默認使用了MySQL 8.0的驅動,所以這里采用com.mysql.cj.jdbc.Driver,而不是老的com.mysql.jdbc.Driver。

    #連接JNDI數據源

    當你將應用部署于應用服務器上的時候想讓數據源由應用服務器管理,那么可以使用如下配置方式引入JNDI數據源。

    spring.datasource.jndi-name=java:jboss/datasources/customers
    

    使用JdbcTemplate操作數據庫

    Spring的JdbcTemplate是自動配置的,你可以直接使用@Autowired或構造函數(推薦)來注入到你自己的bean中來使用。

    下面就來一起完成一個增刪改查的例子:

    準備數據庫

    先創建User表,包含屬性nameage??梢酝ㄟ^執行下面的建表語句:

    CREATE TABLE `User` (
      `name` varchar(100) COLLATE utf8mb4_general_ci NOT NULL,
      `age` int NOT NULL
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci
    

    編寫領域對象

    根據數據庫中創建的User表,創建領域對象:

    @Data
    @NoArgsConstructor
    public class User {
    
        private String name;
        private Integer age;
    
    }
    

    這里使用了Lombok的@Data@NoArgsConstructor注解來自動生成各參數的Set、Get函數以及不帶參數的構造函數。

    編寫數據訪問對象

    • 定義包含有插入、刪除、查詢的抽象接口UserService
    public interface UserService {
    
        /**
         * 新增一個用戶
         *
         * @param name
         * @param age
         */
        int create(String name, Integer age);
    
        /**
         * 根據name查詢用戶
         *
         * @param name
         * @return
         */
        List<User> getByName(String name);
    
        /**
         * 根據name刪除用戶
         *
         * @param name
         */
        int deleteByName(String name);
    
        /**
         * 獲取用戶總量
         */
        int getAllUsers();
    
        /**
         * 刪除所有用戶
         */
        int deleteAllUsers();
    
    }
    
    • 通過JdbcTemplate實現UserService中定義的數據訪問操作
    @Service
    public class UserServiceImpl implements UserService {
    
        private JdbcTemplate jdbcTemplate;
    
        UserServiceImpl(JdbcTemplate jdbcTemplate) {
            this.jdbcTemplate = jdbcTemplate;
        }
    
        @Override
        public int create(String name, Integer age) {
            return jdbcTemplate.update("insert into USER(NAME, AGE) values(?, ?)", name, age);
        }
    
        @Override
        public List<User> getByName(String name) {
            List<User> users = jdbcTemplate.query("select NAME, AGE from USER where NAME = ?", (resultSet, i) -> {
                User user = new User();
                user.setName(resultSet.getString("NAME"));
                user.setAge(resultSet.getInt("AGE"));
                return user;
            }, name);
            return users;
        }
    
        @Override
        public int deleteByName(String name) {
            return jdbcTemplate.update("delete from USER where NAME = ?", name);
        }
    
        @Override
        public int getAllUsers() {
            return jdbcTemplate.queryForObject("select count(1) from USER", Integer.class);
        }
    
        @Override
        public int deleteAllUsers() {
            return jdbcTemplate.update("delete from USER");
        }
    
    }
    

    編寫單元測試用例

    • 創建對UserService的單元測試用例,通過創建、刪除和查詢來驗證數據庫操作的正確性。
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class Chapter31ApplicationTests {
    
        @Autowired
        private UserService userSerivce;
    
        @Before
        public void setUp() {
            // 準備,清空user表
            userSerivce.deleteAllUsers();
        }
    
        @Test
        public void test() throws Exception {
            // 插入5個用戶
            userSerivce.create("Tom", 10);
            userSerivce.create("Mike", 11);
            userSerivce.create("Didispace", 30);
            userSerivce.create("Oscar", 21);
            userSerivce.create("Linda", 17);
    
            // 查詢名為Oscar的用戶,判斷年齡是否匹配
            List<User> userList = userSerivce.getByName("Oscar");
            Assert.assertEquals(21, userList.get(0).getAge().intValue());
    
            // 查數據庫,應該有5個用戶
            Assert.assertEquals(5, userSerivce.getAllUsers());
    
            // 刪除兩個用戶
            userSerivce.deleteByName("Tom");
            userSerivce.deleteByName("Mike");
    
            // 查數據庫,應該有5個用戶
            Assert.assertEquals(3, userSerivce.getAllUsers());
    
        }
    
    }
    

    通過上面這個簡單的例子,我們可以看到在Spring Boot下訪問數據庫的配置依然秉承了框架的初衷:簡單。我們只需要在pom.xml中加入數據庫依賴,再到application.properties中配置連接信息,不需要像Spring應用中創建JdbcTemplate的Bean,就可以直接在自己的對象中注入使用。


    注:本文轉載自“程序猿DD”,如有侵權,請聯系刪除!

    請登錄后查看

    哈哈哈醬 最后編輯于2024-12-18 16:10:10

    快捷回復
    回復
    回復
    回復({{post_count}}) {{!is_user ? '我的回復' :'全部回復'}}
    排序 默認正序 回復倒序 點贊倒序

    {{item.user_info.nickname ? item.user_info.nickname : item.user_name}} LV.{{ item.user_info.bbs_level }}

    作者 管理員 企業

    {{item.floor}}# 同步到gitee 已同步到gitee {{item.is_suggest == 1? '取消推薦': '推薦'}}
    {{item.is_suggest == 1? '取消推薦': '推薦'}}
    沙發 板凳 地板 {{item.floor}}#
    {{item.user_info.title || '暫無簡介'}}
    附件

    {{itemf.name}}

    {{item.created_at}}  {{item.ip_address}}
    打賞
    已打賞¥{{item.reward_price}}
    {{item.like_count}}
    {{item.showReply ? '取消回復' : '回復'}}
    刪除
    回復
    回復

    {{itemc.user_info.nickname}}

    {{itemc.user_name}}

    回復 {{itemc.comment_user_info.nickname}}

    附件

    {{itemf.name}}

    {{itemc.created_at}}
    打賞
    已打賞¥{{itemc.reward_price}}
    {{itemc.like_count}}
    {{itemc.showReply ? '取消回復' : '回復'}}
    刪除
    回復
    回復
    查看更多
    打賞
    已打賞¥{{reward_price}}
    1169
    {{like_count}}
    {{collect_count}}
    添加回復 ({{post_count}})

    相關推薦

    快速安全登錄

    使用微信掃碼登錄
    {{item.label}} 加精
    {{item.label}} {{item.label}} 板塊推薦 常見問題 產品動態 精選推薦 首頁頭條 首頁動態 首頁推薦
    取 消 確 定
    回復
    回復
    問題:
    問題自動獲取的帖子內容,不準確時需要手動修改. [獲取答案]
    答案:
    提交
    bug 需求 取 消 確 定
    打賞金額
    當前余額:¥{{rewardUserInfo.reward_price}}
    {{item.price}}元
    請輸入 0.1-{{reward_max_price}} 范圍內的數值
    打賞成功
    ¥{{price}}
    完成 確認打賞

    微信登錄/注冊

    切換手機號登錄

    {{ bind_phone ? '綁定手機' : '手機登錄'}}

    {{codeText}}
    切換微信登錄/注冊
    暫不綁定
    亚洲欧美字幕
    CRMEB客服

    CRMEB咨詢熱線 咨詢熱線

    400-8888-794

    微信掃碼咨詢

    CRMEB開源商城下載 源碼下載 CRMEB幫助文檔 幫助文檔
    返回頂部 返回頂部
    CRMEB客服