1. 程式人生 > 實用技巧 >HPC叢集安裝指令碼

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. 匯入對應的依賴
  2. 研究依賴如何進行配置
  3. 程式碼如何編寫
  4. 提高擴充套件的技術能力

步驟

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之後

  1. pojo
@Data
@AllArgsConstructor
@NoArgsConstructor public class User {
   private Long id;  
  private String name;   
  private Integer age;    private String email;
}
  1. mapper介面(@MapperScan("com.sj.springbootmybatispuls.mapper")將其掃入進去!
@Repository
public interface UserMapper extends BaseMapper<User> {
    //自帶了CRUD
}
  1. 測試類中測試
@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);    
  }
}

思考?

  1. SQL誰幫我們寫的?MyBatis-Plus都寫好了
  2. 方法哪來的!也是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);

主鍵生成策略

介紹倆個:

  1. 預設 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。可以保證幾乎全球唯 一!

  1. 主鍵自增
  1. 實體類欄位上 @TableId(type = IdType.AUTO)

  2. 資料庫欄位一定要是自增!

  3. 再次測試插入即可

擴:原始碼解釋


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. 資料庫級別(工作中不會讓你修改資料庫1)
  2. 程式碼界別
    • 實體類同步
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 樂觀鎖外掛

  1. 給資料庫新增一個version欄位!預設值取一
  2. 我們實體類加對應的欄位
@Version
 private Integer version;
  1. 配置樂觀鎖
@MapperScan("com.sj.springbootmybatispuls.mapper")
@EnableTransactionManagement
@Configuration
public class MybatisPlusConfig {
    //註冊樂觀鎖外掛
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor(){
        return  new OptimisticLockerInterceptor();
    }
}

  1. 測試
@Test
     public void testUpdate() {
         User user = userMapper.selectById(1);
         user.setName("關注公眾號:狂神說");
         user.setAge(18);
       // 注意:updateById 但是引數是一個 物件!
         int i = userMapper.updateById(user);
         System.out.println(i); }
     }
  1. 切記 一定要先查出來後更新;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);
    }
}

分頁查詢
分頁在網站使用十分之多!

  1. 原始的limit進行分頁
  2. pageHalper第三方外掛
  3. MP內建了分頁外掛!

如何使用

  1. 配置攔截器元件即可
//分頁外掛
@Bean
    public PaginationInterceptor paginationInterceptor(){
        return new PaginationInterceptor();
    }
  1. 直接使用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());
    }

刪除操作

  1. 根據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就可以使用它來替代~!

  1. 測試一,記住檢視輸出的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學習。

   }
  1. 測試二,記住檢視輸出的SQL進行分析
 @Test
    void  test2(){
        //查詢名字
       QueryWrapper<User> wrapper = new QueryWrapper<>();
       wrapper.eq("name","sj");
       User user = userMapper.selectOne(wrapper);//查詢一個數據,出現多個結果使用List或者Map
       System.out.println(user);

   }
  1. 測試三,記住檢視輸出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);
                   
    }
  1. 測試三,記住檢視輸出的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); }
  1. 測試五記住檢視輸出的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); }

  1. 測試六 記住檢視輸出的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&amp;characterEncoding=utf-8&amp;useSSL=false&amp;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();//執行