SpringBoot簡單使用SpringData的jdbc和durid
SpringData的jdbc和durid
創(chuàng)建一個項目,勾選以下選項
項目構(gòu)建完成后pom.xml已導入(springboot默認導入數(shù)據(jù)庫驅(qū)動為8.0,要使用低版本需要手動改版本)
編寫yaml配置文件連接數(shù)據(jù)庫;
spring: datasource: username: root password: 123 url: jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=utf-8 driver-class-name: com.mysql.jdbc.Driver #springBoot數(shù)據(jù)庫驅(qū)動默認為mysql8.0版本,使用8.0以下版本的數(shù)據(jù)庫需要在pom.xml手動更改數(shù)據(jù)庫驅(qū)動版本
因為SpringBoot已經(jīng)默認進行了自動配置;去測試類測試一下
@Test void contextLoads() throws SQLException { //查看一下默認的數(shù)據(jù)源 :class com.zaxxer.hikari.HikariDataSource System.out.println(dataSource.getClass()); //獲得數(shù)據(jù)庫連接 Connection connection=dataSource.getConnection(); System.out.println(connection); //xxxx Template:SpringBoot 已經(jīng)配置好模板bean,拿來即用 CRUD //關(guān)閉 connection.close(); }
查看控制臺,輸出為:
class com.zaxxer.hikari.HikariDataSource
說明沒有問題
HikariDataSource 號稱 Java WEB 當前速度最快的數(shù)據(jù)源,相比于傳統(tǒng)的 C3P0 、DBCP、Tomcat jdbc 等連接池更加優(yōu)秀;
可以使用 spring.datasource.type 指定自定義的數(shù)據(jù)源類型,值為 要使用的連接池實現(xiàn)的完全限定名。
- 有了數(shù)據(jù)庫連接,就可以 CRUD 操作數(shù)據(jù)庫了。使用對象 JdbcTemplate進行操作。
- 即使不使用第三方第數(shù)據(jù)庫操作框架,如 MyBatis等,Spring 本身也對原生的JDBC 做了輕量級的封裝,即JdbcTemplate。
- 數(shù)據(jù)庫操作的所有 CRUD 方法都在 JdbcTemplate 中。
JdbcTemplate主要提供以下幾類方法:
- execute方法:可以用于執(zhí)行任何SQL語句,一般用于執(zhí)行DDL語句;
- update方法及batchUpdate方法:update方法用于執(zhí)行新增、修改、刪除等語句;batchUpdate方法用于執(zhí)行批處理相關(guān)語句;
- query方法及queryForXXX方法:用于執(zhí)行查詢相關(guān)語句;
- call方法:用于執(zhí)行存儲過程、函數(shù)相關(guān)語句。
然后進行編寫測試類,進行crud
創(chuàng)建一個控制類,JDBCController.java
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import java.util.List; import java.util.Map; @RestController public class JDBCController { @Autowired JdbcTemplate jdbcTemplate; //查詢數(shù)據(jù)庫的所有信息 //沒有實體類,數(shù)據(jù)庫中的東西,怎么獲???map @GetMapping("userList") public List<Map<String,Object>> userList(){ String sql="select*from user"; List<Map<String,Object>> mapList=jdbcTemplate.queryForList(sql); return mapList; } //添加一個用戶 @GetMapping("/addUser") public String addUser(){ String sql="insert into mybatis.user(name,pwd) values('笑','123456')"; int n= jdbcTemplate.update(sql); return String.valueOf(n); } //更改一個用戶 @GetMapping("/updateUser/{id}") public String updateUser(@PathVariable("id") int id){ String sql="update mybatis.user set name=?,pwd=? where id="+id; //封裝 Object[] objects=new Object[2]; objects[0] ="小明2"; objects[1] ="456"; int n= jdbcTemplate.update(sql,objects); return String.valueOf(n); } //刪除一個用戶 @GetMapping("/deleteUser/{id}") public String deleteUser(@PathVariable("id") int id){ String sql="delete from mybatis.user where id=?"; int n= jdbcTemplate.update(sql,id); return String.valueOf(n); } }
創(chuàng)建一個數(shù)據(jù)庫:mybatis
然后創(chuàng)建數(shù)據(jù)表:
DROP TABLE IF EXISTS `user`; CREATE TABLE `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(25) CHARACTER SET gbk COLLATE gbk_chinese_ci NULL DEFAULT NULL, `pwd` varchar(25) CHARACTER SET gbk COLLATE gbk_chinese_ci NULL DEFAULT NULL, PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 18 CHARACTER SET = gbk COLLATE = gbk_chinese_ci ROW_FORMAT = Compact; -- ---------------------------- -- Records of user -- ---------------------------- INSERT INTO `user` VALUES (3, '小黑', '789'); INSERT INTO `user` VALUES (4, '可可2', '151'); INSERT INTO `user` VALUES (5, '阿毛', '4566977'); INSERT INTO `user` VALUES (6, '小明', 'cafa1414f'); INSERT INTO `user` VALUES (7, '嘻嘻3', '101112'); INSERT INTO `user` VALUES (8, '很愛很愛你', '101112'); INSERT INTO `user` VALUES (9, '小霞', '159'); INSERT INTO `user` VALUES (10, '嘻嘻5', '101112'); INSERT INTO `user` VALUES (11, '陳', 'dad45'); INSERT INTO `user` VALUES (12, '陳2', 'd2ad45'); INSERT INTO `user` VALUES (13, '小明', '123456'); INSERT INTO `user` VALUES (14, '小明2', '456'); INSERT INTO `user` VALUES (17, '阿毛', '4566977'); SET FOREIGN_KEY_CHECKS = 1;
然后啟動服務,在瀏覽器打開:http://localhost:8080/userList
其它更改,刪除,添加操作也是如此,
Druid 是阿里巴巴開源平臺上一個數(shù)據(jù)庫連接池實現(xiàn),結(jié)合了 C3P0、DBCP 等 DB 池的優(yōu)點,同時加入了日志監(jiān)控. Druid 可以很好的監(jiān)控 DB 池連接和 SQL 的執(zhí)行情況,天生就是針對監(jiān)控而生的 DB 連接池.
然后更改application.yml
spring: datasource: username: root password: 123 url: jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=utf-8 driver-class-name: com.mysql.jdbc.Driver #springBoot數(shù)據(jù)庫驅(qū)動默認為mysql8.0版本,使用8.0以下版本的數(shù)據(jù)庫需要在pom.xml手動更改數(shù)據(jù)庫驅(qū)動版本 #切換為阿里巴巴druid源 type: com.alibaba.druid.pool.DruidDataSource # 自定義數(shù)據(jù)源 #Spring Boot 默認是不注入這些屬性值的,需要自己綁定 #druid 數(shù)據(jù)源專有配置 initialSize: 5 minIdle: 5 maxActive: 20 maxWait: 60000 timeBetweenEvictionRunsMillis: 60000 minEvictableIdleTimeMillis: 300000 validationQuery: SELECT 1 FROM DUAL testWhileIdle: true testOnBorrow: false testOnReturn: false poolPreparedStatements: true #配置監(jiān)控統(tǒng)計攔截的filters,stat:監(jiān)控統(tǒng)計、log4j:日志記錄、wall:防御sql注入 #如果允許時報錯 java.lang.ClassNotFoundException: org.apache.log4j.Priority #則導入 log4j 依賴即可,Maven 地址:https://mvnrepository.com/artifact/log4j/log4j filters: stat,wall,log4j maxPoolPreparedStatementPerConnectionSize: 20 useGlobalDataSourceStat: true connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
然后在pom.xml導入依賴
<!-- https://mvnrepository.com/artifact/com.alibaba/druid --> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.2.5</version> </dependency> <!--log4j--> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.16</version> </dependency>
再次在測試類測試
發(fā)現(xiàn)數(shù)據(jù)源已更改為阿里的:class com.alibaba.druid.pool.DruidDataSource
Druid 數(shù)據(jù)源具有監(jiān)控的功能,并提供了一個 web 界面方便用戶查看,類似安裝 路由器 時,人家也提供了一個默認的 web 頁面。
所以第一步需要設置 Druid 的后臺管理頁面,比如 登錄賬號、密碼 等;配置后臺管理
新建一個配置類:DruidConfig
import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.support.http.StatViewServlet; import com.alibaba.druid.support.http.WebStatFilter; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.web.servlet.FilterRegistrationBean; import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import javax.sql.DataSource; import java.util.HashMap; import java.util.Map; @Configuration public class DruidConfig { @ConfigurationProperties(prefix = "spring.datasource") @Bean public DataSource druidDataSource(){ return new DruidDataSource(); } //后臺監(jiān)控:web.xml,ServletRegistrationBean //因為SpringBoot 內(nèi)置了servlet容器,所以沒有web.xml,替代方法 //訪問:http://localhost:8080/druid @Bean public ServletRegistrationBean statViewServlet(){ ServletRegistrationBean bean= new ServletRegistrationBean<>(new StatViewServlet(),"/druid/*"); //后臺需要有人登錄,賬號密碼配置 HashMap<Object,Object> initParameters=new HashMap<>(); initParameters.put("loginUsername","admin");//登錄key 是固定的loginUserUsername loginPassword initParameters.put("loginPassword","123456"); //允許誰可以訪問 initParameters.put("allow",""); //禁止誰能訪問 initParameters.put("allow","121.0.0.1"); bean.setInitParameters(initParameters);//設置初始化參數(shù) return bean; } //filter @Bean public FilterRegistrationBean webStatFilter(){ FilterRegistrationBean bean=new FilterRegistrationBean(); bean.setFilter(new WebStatFilter()); //可以過濾哪些請求呢? Map<String,String> initParameters=new HashMap<>(); //這些東西不進行統(tǒng)計 initParameters.put("exclusions","*.js,*.css,/druid/*"); bean.setInitParameters(initParameters); return bean; } }
然后啟動項目
瀏覽器打開:
http://localhost:8080/druid,進入登陸頁面,填寫登陸賬號,密碼
進入到監(jiān)控頁面
到此這篇關(guān)于SpringBoot簡單使用SpringData的jdbc和durid的文章就介紹到這了,更多相關(guān)SpringData的jdbc和durid內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java中數(shù)組與集合的相互轉(zhuǎn)換實現(xiàn)解析
這篇文章主要介紹了Java中數(shù)組與集合的相互轉(zhuǎn)換實現(xiàn)解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-08-08SpringBoot實現(xiàn)上傳文件到AWS S3的代碼
這篇文章主要介紹了SpringBoot實現(xiàn)上傳文件到AWS S3的代碼,幫助大家更好的理解和使用springboot框架,感興趣的朋友可以了解下2020-10-10