use h2

Author: Snailclimb

source-code/basis/jpa-demo/pom.xml

@@ -32,6 +32,11 @@
             <artifactId>mysql-connector-java</artifactId>
             <scope>runtime</scope>
         </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <scope>runtime</scope>
+        </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>

source-code/basis/jpa-demo/src/main/resources/application.properties

@@ -1,14 +1,20 @@
-spring.datasource.url=jdbc:mysql://localhost:3306/springboot_jpa?useSSL=false&serverTimezone=CTT
+# 数据库url地址
+spring.datasource.url=jdbc:h2:mem:jpa-demo
 spring.datasource.username=root
 spring.datasource.password=123456
+spring.datasource.platform=h2
+spring.datasource.driverClassName =org.h2.Driver
+
+spring.jpa.properties.hibernate.enable_lazy_load_no_trans=true
 # 打印出 sql 语句
 spring.jpa.show-sql=true
 #常用的有四种：
 # 1.create:每次重新启动项目都会重新创新表结构，会导致数据丢失
 # 2.create-drop:每次启动项目创建表结构，关闭项目删除表结构
 # 3.update:每次启动项目会更新表结构
 # 4. validate:验证表结构，不对数据库进行任何更改
-spring.jpa.hibernate.ddl-auto=create
+spring.jpa.hibernate.ddl-auto=update
 spring.jpa.open-in-view=false
-# 创建的表的 ENGINE 为 InnoDB
-spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL55Dialect
+server.port=8080
+#H2控制台
+spring.h2.console.enabled=true

source-code/basis/springboot-handle-exception-improved/.idea/modules/webApp.main.iml

@@ -1,5 +1,5 @@
 plugins {
-	id 'org.springframework.boot' version '2.1.9.RELEASE'
+	id 'org.springframework.boot' version '2.1.8.RELEASE'
 	id 'java'
 }
 

source-code/basis/springboot-handle-exception-improved/build.gradle

@@ -0,0 +1,36 @@
+package com.example.helloworld.controller;
+
+import java.util.Date;
+
+/**
+ * 这是一个简单的Runnable类，需要大约5秒钟来执行其任务。
+ * @author shuang.kou
+ */
+public class MyRunnable implements Runnable {
+
+    private String command;
+
+    public MyRunnable(String s) {
+        this.command = s;
+    }
+
+    @Override
+    public void run() {
+        System.out.println(Thread.currentThread().getName() + " Start. Time = " + new Date());
+        processCommand();
+        System.out.println(Thread.currentThread().getName() + " End. Time = " + new Date());
+    }
+
+    private void processCommand() {
+        try {
+            Thread.sleep(5000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    public String toString() {
+        return this.command;
+    }
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/BookController.java

@@ -0,0 +1,30 @@
+package com.example.helloworld.controller;
+
+public class Test {
+    public Test() {
+        System.out.print("默认构造方法！--");
+    }
+
+    //非静态代码块
+    {
+        System.out.print("非静态代码块！--");
+    }
+
+    //静态代码块
+    static {
+        System.out.print("静态代码块！--");
+    }
+
+    private static void test() {
+        System.out.print("静态方法中的内容! --");
+        {
+            System.out.print("静态方法中的代码块！--");
+        }
+
+    }
+
+    public static void main(String[] args) {
+        Test test = new Test();
+        Test.test();//静态代码块！--静态方法中的内容! --静态方法中的代码块！--
+    }
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/CountDownLatchExample1.java

@@ -0,0 +1,38 @@
+package com.example.helloworld.controller;
+
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+public class ThreadPoolExecutorDemo {
+
+    private static final int CORE_POOL_SIZE = 5;
+    private static final int MAX_POOL_SIZE = 10;
+    private static final int QUEUE_CAPACITY = 100;
+    private static final Long KEEP_ALIVE_TIME = 1L;
+
+    public static void main(String[] args) {
+
+        //使用阿里巴巴推荐的创建线程池的方式
+        //通过ThreadPoolExecutor构造函数自定义参数创建
+        ThreadPoolExecutor executor = new ThreadPoolExecutor(
+                CORE_POOL_SIZE,
+                MAX_POOL_SIZE,
+                KEEP_ALIVE_TIME,
+                TimeUnit.SECONDS,
+                new ArrayBlockingQueue<>(QUEUE_CAPACITY),
+                new ThreadPoolExecutor.CallerRunsPolicy());
+
+        for (int i = 0; i < 10; i++) {
+            //创建WorkerThread对象（WorkerThread类实现了Runnable 接口）
+            Runnable worker = new MyRunnable("" + i);
+            //执行Runnable
+            executor.execute(worker);
+        }
+        //终止线程池
+        executor.shutdown();
+        while (executor.isTerminated()) {
+            System.out.println("Finished all threads");
+        }
+    }
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/HelloWorldController.java

@@ -0,0 +1,29 @@
+package com.example.helloworld.controller;
+
+import com.example.helloworld.dto.UserDto;
+import com.example.helloworld.entity.User;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.IntStream;
+
+@RestController
+@RequestMapping("users")
+public class UserController {
+
+    ArrayList<User> users = new ArrayList<User>() {{
+        add(new User(11111L, "Guide哥", "koushuangbwcx@163.com", "123456"));
+        add(new User(22222L, "李真", "koushuangbwcx@163.com", "123456"));
+        add(new User(33333L, "帅", "koushuangbwcx@163.com", "123456"));
+    }};
+
+    @GetMapping
+    public ResponseEntity<List<UserDto>> getUsers() {
+
+        return null;
+    }
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/MyBloomFilter.java

@@ -0,0 +1,13 @@
+package com.example.helloworld.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+@Getter
+@Setter
+@ToString
+public class UserDto {
+    String name;
+    String email;
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/MyRunnable.java

@@ -0,0 +1,13 @@
+package com.example.helloworld.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+@Data
+@AllArgsConstructor
+public class User {
+    Long id;
+    String name;
+    String email;
+    String password;
+}

source-code/start/hello-world/src/main/java/com/example/helloworld/controller/Test.java

@@ -0,0 +1,30 @@
+package com.example.dto2entity;
+
+import com.example.helloworld.entity.User;
+import com.example.helloworld.dto.UserDto;
+import org.junit.Test;
+import org.springframework.beans.BeanUtils;
+
+import static org.junit.Assert.assertFalse;
+import static org.springframework.test.util.AssertionErrors.assertTrue;
+
+public class BeanUtilsTest {
+
+    @Test
+    public void should_copy_user_properties_to_userDto() {
+        User user = new User(123213L, "Guide哥", "koushuangbwcx@163.com", "123456");
+        UserDto userDto = new UserDto();
+        BeanUtils.copyProperties(user, userDto);
+        assertTrue("name copied", userDto.getName().equals(user.getName()));
+        assertTrue("email copied", userDto.getEmail().equals(user.getEmail()));
+    }
+
+    @Test
+    public void should_copy_user_properties_to_userDto_but_not_copy_email() {
+        User user = new User(123213L, "Guide哥", "koushuangbwcx@163.com", "123456");
+        UserDto userDto = new UserDto();
+        BeanUtils.copyProperties(user, userDto, "email");
+        assertTrue("name copied", userDto.getName().equals(user.getName()));
+        assertTrue("email not copied", userDto.getEmail() == null);
+    }
+}