Spring Boot數據庫交互

時間  2019-11-12
標籤 spring boot 數據庫 交互 欄目 Spring 简体版
原文   原文鏈接

 在上篇文件的基礎上進行開發，簡單實現一下增、查操做，刪除和修改相似，做爲一個demo就暫時不作重複工做了，實現原理相似css

IDEA建立Spring Boot項目

項目結構

 

新建MySQL數據庫相關信息

-- 建數據庫
create database if not exists test;

-- 建表
CREATE TABLE `user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(30) NOT NULL,
  `password` varchar(30) NOT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `name_UNIQUE` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8;

maven中增長配置四個架包

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

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

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

        <!-- 很是重要，缺乏這個架包，會致使html沒法正常解析，會產生Whitelabel Error Page錯誤，而且控制層傳值沒法正常獲取-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>

 

配置文件 application.properties

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF8&zeroDateTimeBehavior=convertToNull&useSSL=true&allowMultiQueries=true&serverTimezone=Asia/Hong_Kong
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.tomcat.max-wait=10000
spring.datasource.tomcat.max-active=50
spring.datasource.tomcat.test-on-borrow=true
spring.datasource.testWhileIdle = true
spring.datasource.timeBetweenEvictionRunsMillis = 60000
# 暫時用不到
spring.mvc.view.prefix=/templates/
# 暫時用不到
spring.mvc.view.suffix=.html

 

創建實體類 User.java

package com.springboot.demo.domain;

import javax.persistence.*;

@Entity
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;
    private String name;
    private String password;

    public Long getId() {
        return id;
    }

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

    public String getName() {
        return name;
    }

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

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

 

創建持久層接口 UserDao.java

package com.springboot.demo.dao;

import com.springboot.demo.domain.User;

import java.util.List;

public interface UserDao {
    /**
     * 插入一個用戶
     * @param user
     * @return
     */
    Long insertUser(User user);

    /**
     * 經過用戶名獲取用戶，用戶名惟一
     * @param name
     * @return
     */
    User getUserByName(String name);

    /**
     * 列出全部的用戶信息
     * @return
     */
    List<User> getAllUsers();

    /**
     * 刪除暫不實現
     * @param user
     */
    void delete(User user);

    /**
     * 修改暫不實現
     * @param user
     */
    void update(User user);
}

 

實現持久層接口 UserRepository.java

package com.springboot.demo.domain;

import com.springboot.demo.dao.UserDao;
import com.springboot.demo.utils.RowMapperFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.stereotype.Repository;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Repository
public class UserRepository implements UserDao {

    @Autowired
    private NamedParameterJdbcTemplate jdbcTemplate;

    @Override
    public User getUserByName(String name) {
        String sql = "select * from User user where name=:name";
        Map<String, Object> param = new HashMap<>();
        param.put("name", name);
        return jdbcTemplate.queryForObject(sql, param, RowMapperFactory.getInstance(User.class));
    }

    @Override
    public Long insertUser(User user) {
        String sql = "insert into user(name, password) values(:name, :password)";
        Map<String, Object> param = new HashMap<>();
        param.put("name", user.getName());
        param.put("password", user.getPassword());
        return (long) jdbcTemplate.update(sql, param);
    }

    @Override
    public List<User> getAllUsers() {
        String sql = "select * from User user";
        Map<String, Object> param = new HashMap<>();
        return jdbcTemplate.query(sql, param, RowMapperFactory.getInstance(User.class));
    }

    @Override
    public void delete(User user) {

    }

    @Override
    public void update(User user) {

    }
}

 

創建服務層類 UserService.java

package com.springboot.demo.service;

import com.springboot.demo.dao.UserDao;
import com.springboot.demo.domain.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.Objects;

@Service
public class UserService {
    @Autowired
    private UserDao userDao;

    /**
     * 經過用戶名獲取用戶，用戶名惟一
     * @param name
     * @return
     */
    public User getUserByName(String name) {
       return userDao.getUserByName(name);
    }

    /**
     * 插入一個用戶
     * @param user
     * @return
     */
    public Long insertUser(User user) {
        User userDb = getUserByName(user.getName());
        if(Objects.isNull(userDb))
            return userDao.insertUser(user);
        else return userDb.getId();
    }

    /**
     * 列出全部的用戶信息
     * @return
     */
    public List<User> getAllUsers() {
        return userDao.getAllUsers();
    }
}

 

創建控制層類 LoginController.java

package com.springboot.demo.web;

import com.springboot.demo.domain.User;
import com.springboot.demo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

import java.util.List;
import java.util.Objects;

@Controller
@RequestMapping("/admin")
public class LoginController {

    @Autowired
    private UserService userService;

    @RequestMapping(value="/userInfo")
    public String userInfo(Model model) {
        String managerName = "Jef";
        User userDb = userService.getUserByName(managerName);
        if(Objects.isNull(userDb)) {
            userDb = new User();
            userDb.setName(managerName);
            userDb.setPassword("123");
            userService.insertUser(userDb);
        }
        model.addAttribute("manager", managerName);
        List<User> users = userService.getAllUsers();
        model.addAttribute("users", users);
        return "index";
    }
}

 

工具類 RowMapperFactory.java

package com.springboot.demo.utils;

import org.springframework.jdbc.core.RowMapper;

import java.lang.reflect.Method;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;


public class RowMapperFactory {

    public static <K> RowMapper<K> getInstance(Class<K> clazz) {
        return getRowMapper(clazz);
    }

    public static <K> RowMapper<K> getRowMapper(Class<K> clazz) {

        return new RowMapper<K>() {

            private AutoRowMapper<K> rm = new AutoRowMapper(clazz);

            @Override
            public K mapRow(ResultSet rs, int rowNum) throws SQLException {
                try {
                    return rm.mapRow(rs, rowNum, clazz.newInstance());
                }
                catch (InstantiationException | IllegalAccessException e) {
                    e.printStackTrace();
                    return null;
                }
            }
        };
    }

    /**
     * 這是一個用於簡化 rowMapper 的編寫輔助類。
     * <p/>
     * 本類會自動跳過 entity 中存在，可是在查詢語句中不存在的列。
     *
     * @param <T> entity type
     */
    private static class AutoRowMapper<T> {

        private Map<String, String> colName2SetterMap = new HashMap<>(); // 數據列名到 setter 名稱的映射
        private Map<String, Method> setterMap = new HashMap<>();         // setter 名稱到 setter 方法的映射
        private Map<String, String> setterParamMap = new HashMap<>();    // setter 名稱到 setter 參數類型的映射

        /**
         * 初始化
         *
         * @param t 實體類的類對象
         */
        protected <T> AutoRowMapper(Class<T> t) {
            Method[] ms = t.getMethods();
            for (int i = 0; i < ms.length; i++) {
                String name = ms[i].getName();
                if (name.startsWith("set") && ms[i].getParameterCount() == 1) {
                    setterMap.put(name, ms[i]);
                    setterParamMap.put(name, ms[i].getGenericParameterTypes()[0].getTypeName());
                    colName2SetterMap.put(setterToColName(name), name);
                }
            }
        }

        /**
         * 在子類中，要實現的 RowMapper.mapRow 中掉用此方法。
         *
         * @param rs     結果集
         * @param rowNum 結果集行號
         * @param t      entity 對象，用於裝填查詢結果行數據
         * @return 傳入的 entity 對象
         */
        public T mapRow(ResultSet rs, int rowNum, T t) {

            for (String col : colName2SetterMap.keySet()) {
                try {
                    int index = rs.findColumn(col); // 若是找不到列，就會拋出異常
                    String setterName = colName2SetterMap.get(col);
                    inject(setterMap.get(setterName), setterParamMap.get(setterName), rs, index, t);
                } catch (SQLException ex) {
                    continue;
                }
            }
            return t;
        }

        /**
         * 把 setter 名稱轉換爲列名。如 setCreatedOn --> created_on
         */
        private static String setterToColName(String setterName) {
            String property = setterName.substring(3, setterName.length());
            StringBuilder sb = new StringBuilder().append(property.charAt(0));
            for(int i = 1; i < property.length(); i++) {
                char c = property.charAt(i);
                if(Character.isUpperCase(c)) {
                    sb.append("");
                }
                sb.append(c);
            }
            return sb.toString().toLowerCase();
        }

        /**
         * 把指定列按類型注入 entity.
         * <p/>
         * 目前支持的類字段類型有：
         * <pre>
         * java.lang.Boolean    boolean
         * java.lang.Byte       byte
         * java.lang.Long       long
         * java.lang.Integer    int
         * java.lang.Short      short
         * java.lang.Float      float
         * java.lang.Double     double
         * java.lang.Date
         * java.lang.String
         * java.sql.Blob
         * java.math.BigDecimal
         * </pre>
         */
        private void inject(Method getter, String fieldType, ResultSet rs, int index, T t) {
            try {

                switch (fieldType) {
                    case "java.lang.Boolean":  // 布爾值
                    case "boolean":
                        getter.invoke(t, rs.getBoolean(index));
                        break;
                    case "java.lang.Byte":     // 字節
                    case "byte":
                        getter.invoke(t, rs.getByte(index));
                        break;
                    case "java.lang.Long":     // Long
                    case "long":
                        getter.invoke(t, rs.getLong(index));
                        break;
                    case "java.lang.Integer":  // Int
                    case "int":
                        getter.invoke(t, rs.getInt(index));
                        break;
                    case "java.lang.Short":    // Short
                    case "short":
                        getter.invoke(t, rs.getShort(index));
                        break;
                    case "java.lang.Float":    // Float
                    case "float":
                        getter.invoke(t, rs.getFloat(index));
                        break;
                    case "java.lang.Double":   // Double
                    case "double":
                        getter.invoke(t, rs.getDouble(index));
                        break;
                    case "java.lang.Date":
                        getter.invoke(t, rs.getDate(index));
                        break;
                    case "java.lang.String":
                        getter.invoke(t, rs.getString(index));
                        break;
                    case "java.sql.Blob":
                        getter.invoke(t, rs.getBlob(index));
                        break;
                    case "java.math.BigDecimal":
                        getter.invoke(t, rs.getBigDecimal(index));
                        break;
                    default:
                        getter.invoke(t, rs.getObject(index));
                        break;
                }
            }
            catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }
}

 

頁面展現文件 index.html

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="utf-8">
    <meta http-equiv="Content-Type" content="text/html">
    <title>Spring Boot User</title>
    <link rel="stylesheet" type="text/css" media="all" href="/css/bootstrap.min.css">
</head>
<body>
<!-- Thymeleaf 經常使用屬性進行取值 -->
<h1>取控制層傳過來的值</h1>
<h1>Manager = </h1>
<td class="text" th:text="${manager}" ></td>
<h1>測試JS是否有效</h1>
<p id="testId"></p>
<h1>把全部用戶信息列出來</h1>
<ul class="timeline">
    <div th:each="entry, status : ${users}">
        <li th:attr="class=${status.odd} ? 'timeline-inverted' : ''">
            <div class="tl-circ"></div>
            <div class="timeline-panel">
                <div class="tl-heading">
                    <h4><span th:text="${entry.name}">TITLE</span></h4>
                </div>
            </div>
        </li>
    </div>
</ul>
<script src="/js/jquery-3.1.1.js"></script>
<script>
    $(document).ready(function () {
        $( "#testId" ).text( "Test Id" );
    });
</script>
</body>
</html>

其中css、js文件，拷貝文件名去搜索能夠直接進入他們的官網下載html

 

啓動Spring Boot項目的類 DemoApplication.java

package com.springboot.demo;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;

@EnableAutoConfiguration
@SpringBootApplication
// 自動掃描下面配置的包
@ComponentScan({"com.springboot.demo"})
public class DemoApplication {
    private static final Logger log = LoggerFactory.getLogger(DemoApplication.class);

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

 

運行結果

http://localhost:8080/admin/userInfojava

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程