HPC叢集安裝指令碼
注:學習自狂神
MyBatisPlus概述
為什麼要學習它呢?MyBatisPlus可以節省我們大量工作時間,所有的CRUD程式碼它都可以自動化完成!
簡介
是什麼? MyBatis 本來就是簡化 JDBC 操作的! 官網:https://mp.baomidou.com/ ,簡化 MyBatis !
特性
- 無侵入:只做增強不做改變,引入它不會對現有工程產生影響,如絲般順滑
- 損耗小:啟動即會自動注入基本 CURD,效能基本無損耗,直接面向物件操作, BaseMapper
- 強大的 CRUD 操作:內建通用 Mapper、通用 Service,僅僅通過少量配置即可實現單表大部分 CRUD 操作,更有強大的條件構造器,滿足各類使用需求, 以後簡單的CRUD操作,它不用自己編寫 了!
- 支援 Lambda 形式呼叫:通過 Lambda 表示式,方便的編寫各類查詢條件,無需再擔心欄位寫錯
- 支援主鍵自動生成:支援多達 4 種主鍵策略(內含分散式唯一 ID 生成器 - Sequence),可自由配 置,完美解決主鍵問題
- 支援 ActiveRecord 模式:支援 ActiveRecord 形式呼叫,實體類只需繼承 Model 類即可進行強大 的 CRUD 操作
- 支援自定義全域性通用操作:支援全域性通用方法注入( Write once, use anywhere )
- 內建程式碼生成器:採用程式碼或者 Maven 外掛可快速生成 Mapper 、 Model 、 Service 、 Controller 層程式碼,支援模板引擎,更有超多自定義配置等您來使用(自動幫你生成程式碼)
- 內建分頁外掛:基於 MyBatis 物理分頁,開發者無需關心具體操作,配置好外掛之後,寫分頁等同 於普通 List 查詢
- 分頁外掛支援多種資料庫:支援 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、 Postgre、SQLServer 等多種資料
- 內建效能分析外掛:可輸出 Sql 語句以及其執行時間,建議開發測試時啟用該功能,能快速揪出慢 查詢
- 內建全域性攔截外掛:提供全表 delete 、 update 操作智慧分析阻斷,也可自定義攔截規則,預防誤 操作
快速入門
地址:https://mp.baomidou.com/guide/quick-start.html#
使用第三方元件:
- 匯入對應的依賴
- 研究依賴如何進行配置
- 程式碼如何編寫
- 提高擴充套件的技術能力
步驟
1. 創建出一個mybatis_plus
2. 建立一個user表
DROP TABLE IF EXISTS user;
CREATE TABLE user (
id BIGINT(20) NOT NULL COMMENT '主鍵ID',
name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名',
age INT(11) NULL DEFAULT NULL COMMENT '年齡', email VARCHAR(50) NULL DEFAULT NULL COMMENT '郵箱',
PRIMARY KEY (id) );
INSERT INTO user (id, name, age, email) VALUES (1, 'Jone', 18, '[email protected]'), (2, 'Jack', 20, '[email protected]'), (3, 'Tom', 28, '[email protected]'), (4, 'Sandy', 21, '[email protected]'), (5, 'Billie', 24, '[email protected]');
-- 真實開發中,version(樂觀鎖)、deleted(邏輯刪除)、gmt_create、gmt_modified
3. 編寫專案,初始化專案!使用SpringBoot初始化!
4. 匯入依賴
<!-- 資料庫驅動 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId> </dependency>
<!-- lombok -->
<dependency>
<groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId>
</dependency>
<!-- mybatis-plus --> <!-- mybatis-plus 是自己開發,並非官方的! -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId> <version>3.0.5</version>
</dependency>
說明:我們使用 mybatis-plus 可以節省我們大量的程式碼,儘量不要同時匯入 mybatis 和 mybatisplus!版本的差異!
5. 連線資料庫!這一步和mybatis相同!
# mysql 5 驅動不同 com.mysql.jdbc.Driver
# mysql 8 驅動不同com.mysql.cj.jdbc.Driver、需要增加時區的配置 serverTimezone=GMT%2B8 spring.datasource.username=root spring.datasource.password=123456 spring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus? useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
傳統方式pojo-dao(連線mybatis,配置mapper.xml檔案)service-controller
6. 使用mybatis-plus之後
- pojo
@Data
@AllArgsConstructor
@NoArgsConstructor public class User {
private Long id;
private String name;
private Integer age; private String email;
}
- mapper介面(@MapperScan("com.sj.springbootmybatispuls.mapper")將其掃入進去!
@Repository
public interface UserMapper extends BaseMapper<User> {
//自帶了CRUD
}
- 測試類中測試
@MapperScan("com.sj.springbootmybatispuls.mapper"
@SpringBootTest
class MybatisPlusApplicationTests {
// 繼承了BaseMapper,所有的方法都來自己父類 // 我們也可以編寫自己的擴充套件方法!
@Autowired
private UserMapper userMapper;
@Test
void contextLoads() {
// 引數是一個 Wrapper ,條件構造器,這裡我們先不用 null
// 查詢全部使用者
List<User> users = userMapper.selectList(null); users.forEach(System.out::println);
}
}
思考?
- SQL誰幫我們寫的?MyBatis-Plus都寫好了
- 方法哪來的!也是MyBatis都寫好的
配置日誌
sql不可見需要配置日誌,來檢視執行的!
# 配置日誌
mybatis-plus.configuration.logimpl=org.apache.ibatis.logging.stdout.StdOutImpl
CRUD擴充套件
插入操作insert
@Test
public void insert(){
User user = new User();
user.setId(6);
user.setName("狂神說Java");
user.setAge(3);
user.setEmail("[email protected]");
int insert = userMapper.insert(user);
System.out.println(insert);
主鍵生成策略
介紹倆個:
- 預設 ID_WORKER 全域性唯一id
分散式系統唯一id生成:https://www.cnblogs.com/haoxinyue/p/5208136.html
雪花演算法:
snowflake是Twitter開源的分散式ID生成演算法,結果是一個long型的ID。其核心思想是:使用41bit作為 毫秒數,10bit作為機器的ID(5個bit是資料中心,5個bit的機器ID),12bit作為毫秒內的流水號(意味 著每個節點在每毫秒可以產生 4096 個 ID),後還有一個符號位,永遠是0。可以保證幾乎全球唯 一!
- 主鍵自增
-
實體類欄位上 @TableId(type = IdType.AUTO)
-
資料庫欄位一定要是自增!
-
再次測試插入即可
擴:原始碼解釋
public enum IdType {
AUTO(0),
NONE(1),
INPUT(2),
ASSIGN_ID(3),
ASSIGN_UUID(4),
/** @deprecated */
@Deprecated
ID_WORKER(3),
/** @deprecated */
@Deprecated
ID_WORKER_STR(3),
/** @deprecated */
@Deprecated
UUID(4);
更新操作
@Test
public void testUpdate() {
User user = new User();
//通過條件自動拼接動態sql
user.setId(6);
user.setName("關注公眾號:狂神說");
user.setAge(18);
// 注意:updateById 但是引數是一個 物件!
int i = userMapper.updateById(user);
System.out.println(i); }
}
所有的sql都是自動幫你動態配置的!
自動填充
建立時間、修改時間!這些個操作一遍都是自動化完成的,我們不希望手動更新!
阿里巴巴開發手冊:所有的資料庫表:gmt_create、gmt_modified幾乎所有的表都要配置上!而且需 要自動化!
- 資料庫級別(工作中不會讓你修改資料庫1)
- 程式碼界別
- 實體類同步
private Date createTime;
private Date updateTime;
3. 在實體類屬性上面添加註解
@TableField(fill = FieldFill.INSERT)
private Date creatTime;
@TableField(fill = FieldFill.INSERT_UPDATE)
5. 編寫處理器來處理這個註解即可!
@Slf4j
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
@Override
public void insertFill(MetaObject metaObject) {
log.info("start insert fill.....");
this.setFieldValByName("creatTime",new Date(),metaObject);
this.setFieldValByName("updateTime",new Date(),metaObject);
}
@Override
public void updateFill(MetaObject metaObject) {
log.info("start update fill.....");
this.setFieldValByName("updateTime",new Date(),metaObject);
}
}
注意:
資料庫需要寫creat_Time,update_Time,但是實體類寫上creatTime,updateTime。
樂觀鎖和悲觀鎖
樂觀鎖:顧名思義十分樂觀,他總認為不會出事,如果出現問題,
再次更新值測試!
悲觀鎖:十分悲觀,它總認為出現問題,無論幹嘛都上鎖!再去操作!
我們這裡主要講解樂觀鎖機制!
樂觀鎖實現方式:
- 取出記錄時,獲取當前的version
- 更新時,帶上version
- 執行跟新是,set version = newVersion whereversion = oldVersion
- 如果verison不正確,就跟新失敗!
樂觀鎖:1.先查詢,獲取版本號 version = 1
--A
update user set name = "sj" ,version = version + 1
where id = 2 and version = 1
--B
update user set name = "sj",version = version + 1
where id = 2 and version = 1
測試一下MP 樂觀鎖外掛
- 給資料庫新增一個version欄位!預設值取一
- 我們實體類加對應的欄位
@Version
private Integer version;
- 配置樂觀鎖
@MapperScan("com.sj.springbootmybatispuls.mapper")
@EnableTransactionManagement
@Configuration
public class MybatisPlusConfig {
//註冊樂觀鎖外掛
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor(){
return new OptimisticLockerInterceptor();
}
}
- 測試
@Test
public void testUpdate() {
User user = userMapper.selectById(1);
user.setName("關注公眾號:狂神說");
user.setAge(18);
// 注意:updateById 但是引數是一個 物件!
int i = userMapper.updateById(user);
System.out.println(i); }
}
- 切記 一定要先查出來後更新;update自身帶鎖。直接update不會出現併發修改問題。樂觀鎖是先查詢在修改,where條件是
version = 查詢出來的version值,商品ID為傳入的商品ID,整條update語句為
Update 商品表 set 庫存 = 庫存 - 購買量 ,version = 查詢version值+1 where version = #{查詢的version值} and 商品ID= #{商品ID}
查詢操作
//測試查詢
@Test
public void testSelectById(){
List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
users.forEach(System.out::println);
}
@Test
public void testSelectByBatchIds(){
HashMap<String,Object> map = new HashMap<>();
map.put("name","sj");
map.put("age",3);
List<User> users = userMapper.selectByMap(map);
users.forEach(System.out::println);
}
}
分頁查詢
分頁在網站使用十分之多!
- 原始的limit進行分頁
- pageHalper第三方外掛
- MP內建了分頁外掛!
如何使用
- 配置攔截器元件即可
//分頁外掛
@Bean
public PaginationInterceptor paginationInterceptor(){
return new PaginationInterceptor();
}
- 直接使用Page物件進行即可!
@Test
public void testPage(){
//引數一:當前頁
//引數二:頁面大小
//使用分頁外掛之後,所有的分頁操作也變得簡單的!
Page<User> page = new Page<>(2,5);
Page<User> page1 = userMapper.selectPage(page, null);
page.getRecords().forEach(System.out::println);
System.out.println(page.getTotal());
}
刪除操作
- 根據id刪除資料
@Test
public void testDeleteById(){
userMapper.deleteById(1);
}
@Test
public void testDeletedBatchId(){
userMapper.deleteBatchIds(Arrays.asList(1,2,3));
}
@Test
public void testDeleteMap(){
HashMap<String,Object> map = new HashMap<>();
map.put("name","sj");
userMapper.deleteByMap(map);
}
##### 邏輯刪除
==**物理刪除==:**從資料庫中直接刪除
==**邏輯刪除==:**再資料庫中沒有被移除,而是通過一個變數來讓他失效!delete = 0 =》delete = 1
管理員可以檢視被刪除的記錄!防止資料丟失,類似於回收站!
測試:
1. 在資料表中增加一個deleted欄位
2. 新增依賴
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus- extension</artifactId>
<version>3.0.5</version>
</dependency>
3. 在實體類中增添屬性
@TableLogic//邏輯刪除
private Integer deleted;
4. 配置
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0
5. 測試一下刪除!
@Test
public void testDeleteById1(){
userMapper.deleteById(1);
}
6.結果
注意:3.1.1開始不再需要圖片中的這步,yml配置如果和預設一樣不需要配置
效能分析外掛
我們平時開發中,會遇到一些慢的sql。測試!druid。。。
作用:效能分析攔截器,用於輸出每條sql語句及其執行時間
MP也提供了效能分析外掛,如果超過這個時間就會立刻停止執行!
注意:在3.2之後移除自帶外掛,推薦使用第三方,druid。
條件構造器
十分重要:Wrapper
我們寫一些複雜的sql就可以使用它來替代~!
- 測試一,記住檢視輸出的SQL進行分析
@Test
void testWrapper(){
//查詢name不為空的使用者,並且郵箱不為空的使用者,年齡大於等於12
QueryWrapper<User> wrapper = new QueryWrapper<>();
wrapper.isNotNull("name")
.isNotNull("email")
.ge("age",12);
userMapper.selectList(wrapper).forEach(System.out::println);
//對比以前map學習。
}
- 測試二,記住檢視輸出的SQL進行分析
@Test
void test2(){
//查詢名字
QueryWrapper<User> wrapper = new QueryWrapper<>();
wrapper.eq("name","sj");
User user = userMapper.selectOne(wrapper);//查詢一個數據,出現多個結果使用List或者Map
System.out.println(user);
}
- 測試三,記住檢視輸出sql進行分析
@Test
void test3(){
//查詢年級在20~30歲之間的使用者
QueryWrapper<User> wrapper = new QueryWrapper<>();
wrapper.between("age",20,30);
List<Map<String,Object>> maps = userMapper.selectCount(wrapper);
maps.forEach(System.out::println);
}
- 測試三,記住檢視輸出的SQL進行分析
// 模糊查詢
@Test void test4(){
// 查詢年齡在 20 ~ 30 歲之間的使用者
QueryWrapper<User> wrapper = new QueryWrapper<>();
// 左和右 t% wrapper
.notLike("name","e")
.likeRight("email","t");
List<Map<String, Object>> maps = userMapper.selectMaps(wrapper); maps.forEach(System.out::println); }
- 測試五記住檢視輸出的SQL進行分析
// 模糊查詢
@Test void test5(){
QueryWrapper<User> wrapper = new QueryWrapper<>();
// id 在子查詢中查出來
wrapper.inSql("id","select id from user where id<3");
List<Object> objects = userMapper.selectObjs(wrapper); objects.forEach(System.out::println); }
- 測試六 記住檢視輸出的SQL進行分析
//測試六
@Test void test6(){
QueryWrapper<User> wrapper = new QueryWrapper<>();
// 通過id進行排序
wrapper.orderByAsc("id");
List<User> users = userMapper.selectList(wrapper); users.forEach(System.out::println); }
程式碼自動生成器
AutoGenerator 是 MyBatis-Plus 的程式碼生成器,通過 AutoGenerator 可以快速生成 Entity、Mapper、Mapper XML、Service、Controller 等各個模組的程式碼,極大的提升了開發效率。
1. 新增pom的依賴
<!-- mybatisPlus 程式碼生成器 -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.3.1.tmp</version>
</dependency>
<!-- mybatisPlus Velocity 模版引擎 -->
<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity-engine-core</artifactId>
<version>2.2</version>
</dependency>
<!-- mybatisPlus Freemarker 模版引擎 -->
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.29</version>
</dependency>
2. 程式碼生成
public static void main(String[] args) {
//需要構建一個 程式碼自動生成器 物件
AutoGenerator mpg = new AutoGenerator();
//配置策略
//1.全域性配置
GlobalConfig gc = new GlobalConfig();
String property = System.getProperty("user.dir");//獲取當前的工作路徑
gc.setOutputDir(property + "/src/main/java");
gc.setAuthor("sj");
gc.setOpen(false);
gc.setFileOverride(false); // 是否覆蓋
gc.setServiceName("%sService"); // 去Service的I字首
gc.setIdType(IdType.ID_WORKER);
gc.setDateType(DateType.ONLY_DATE);
gc.setSwagger2(true);
mpg.setGlobalConfig(gc);
//設定資料來源
DataSourceConfig dsc = new DataSourceConfig();
dsc.setUrl("jdbc:mysql://localhost:3306/mybatis-puls?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai");
dsc.setDriverName("com.mysql.jdbc.Driver");
dsc.setUsername("root");
dsc.setPassword("123456");
dsc.setDbType(DbType.MYSQL);
mpg.setDataSource(dsc);
//包配置
PackageConfig pc = new PackageConfig();
pc.setParent("com.sj");
pc.setEntity("entity");
pc.setMapper("mapper");
pc.setService("service");
pc.setController("controller");
mpg.setPackageInfo(pc);
//策略配置
StrategyConfig strategy = new StrategyConfig();
strategy.setInclude("user");
strategy.setNaming(NamingStrategy.underline_to_camel); //轉化駝峰命名
strategy.setColumnNaming(NamingStrategy.underline_to_camel);
strategy.setEntityLombokModel(true); // 自動lombok
strategy.setLogicDeleteFieldName("deleted");//邏輯刪除
//自動填充配置
TableFill createTime = new TableFill("creat_time", FieldFill.INSERT);
TableFill updateTime= new TableFill("update_time", FieldFill.INSERT_UPDATE);
ArrayList<TableFill> list = new ArrayList<>();
list.add(createTime);
list.add(updateTime);
strategy.setTableFillList(list);
//樂觀鎖
strategy.setVersionFieldName("version");
strategy.setRestControllerStyle(true);
strategy.setControllerMappingHyphenStyle(true);//localhost:8080/hello_id_2
mpg.setStrategy(strategy);
mpg.execute();//執行