qrzday02

src/main/java/com/sf/quanrizhi/Column.java → src/main/java/com/sf/quanrizhi/day01/Column.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 import jdk.internal.org.objectweb.asm.tree.analysis.Value;
 

src/main/java/com/sf/quanrizhi/Data.java → src/main/java/com/sf/quanrizhi/day01/Data.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 import java.util.ArrayList;
 import java.util.List;

src/main/java/com/sf/quanrizhi/MyPredicate.java → src/main/java/com/sf/quanrizhi/day01/MyPredicate.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 @FunctionalInterface
 public interface MyPredicate {
     boolean test(Product product);

src/main/java/com/sf/quanrizhi/Product.java → src/main/java/com/sf/quanrizhi/day01/Product.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 public class Product {
     private Long    id;         // 序号

src/main/java/com/sf/quanrizhi/Student.java → src/main/java/com/sf/quanrizhi/day01/Student.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 public class Student {
     private Integer id;

src/main/java/com/sf/quanrizhi/Student1.java → src/main/java/com/sf/quanrizhi/day01/Student1.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 /**
  * SELECT   id , name  FROM  Student

src/main/java/com/sf/quanrizhi/T.java → src/main/java/com/sf/quanrizhi/day01/T.java

@@ -1,7 +1,6 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 import org.junit.Test;
-import sun.java2d.pipe.AAShapePipe;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -25,16 +24,16 @@ public class T {
         User user = new User();
         Class<? extends User> aClass = user.getClass();
         //3
-        Class<?> aClass1 = Class.forName("com.sf.quanrizhi.User");
+        Class<?> aClass1 = Class.forName("com.sf.quanrizhi.day01.User");
 
         //4
         ClassLoader classLoader = this.getClass().getClassLoader();
-        Class<?> aClass2 = classLoader.loadClass("com.sf.quanrizhi.User");
+        Class<?> aClass2 = classLoader.loadClass("com.sf.quanrizhi.day01.User");
     }
 
     @Test
     public void t2() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchMethodException {
-        Class<?> clazz = Class.forName("com.sf.quanrizhi.Student");
+        Class<?> clazz = Class.forName("com.sf.quanrizhi.day01.Student");
         Object o = clazz.newInstance();
         Student student = null;
         if(o instanceof Student){
@@ -178,7 +177,7 @@ public class T {
     @Test
     public void t5() throws ClassNotFoundException, NoSuchFieldException, InstantiationException, IllegalAccessException {
         // 获取student对象的class对象
-        Class<?> clazz = Class.forName("com.sf.quanrizhi.Student");
+        Class<?> clazz = Class.forName("com.sf.quanrizhi.day01.Student");
         //获取对象属性
         Field idFiled = clazz.getDeclaredField("id");
         //取消java语言访问权限
@@ -201,7 +200,7 @@ public class T {
      */
     @Test
     public void t7() throws ClassNotFoundException, NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException {
-        Class<?> clazz = Class.forName("com.sf.quanrizhi.Student");
+        Class<?> clazz = Class.forName("com.sf.quanrizhi.day01.Student");
         Method setNameMethod = clazz.getDeclaredMethod("setName", String.class);
         //实例化对象
         Object obj = clazz.newInstance();
@@ -217,7 +216,7 @@ public class T {
     @Test
     public void t8() throws ClassNotFoundException, NoSuchMethodException, InvocationTargetException, IllegalAccessException {
 //        Student.printInfo();
-        Class<?> clazz = Class.forName("com.sf.quanrizhi.Student");
+        Class<?> clazz = Class.forName("com.sf.quanrizhi.day01.Student");
         Method printInfo = clazz.getMethod("printInfo",String.class);
         printInfo.invoke(null,"zs");
     }

src/main/java/com/sf/quanrizhi/Table.java → src/main/java/com/sf/quanrizhi/day01/Table.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 import java.lang.annotation.*;
 

src/main/java/com/sf/quanrizhi/User.java → src/main/java/com/sf/quanrizhi/day01/User.java

@@ -1,4 +1,4 @@
-package com.sf.quanrizhi;
+package com.sf.quanrizhi.day01;
 
 public class User {
     private Integer id;

src/main/java/com/sf/quanrizhi/day02/Te.java

@@ -0,0 +1,207 @@
+package com.sf.quanrizhi.day02;
+
+import com.sun.org.apache.bcel.internal.generic.IUSHR;
+import org.junit.Test;
+
+import java.io.PipedOutputStream;
+import java.sql.*;
+import java.sql.Date;
+import java.util.*;
+import java.util.function.Function;
+import java.util.function.Predicate;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * Stream流操作
+ */
+public class Te {
+
+    /**
+     * 操作1：对每个元素求平方
+     * 操作2：请找出数组中的偶数元素
+     * 操作3：对偶数进行升序排序
+     * 操作4：打印
+     */
+    @Test
+    public void t1(){
+        List<Integer> list = Arrays.asList(4, 1, 2, 3);
+        // 1   创建stream流
+        Stream<Integer> stream = list.stream();
+        // 中间操作
+        stream
+                .map(e -> e*e)
+                .filter(e -> e%2 == 0)
+                .sorted()
+                .forEach(e -> System.out.println(e));
+    }
+
+    @Test
+    public void t2(){ //  4  1 2 3
+        Arrays.asList(4, 1,1,4,2, 2, 3).stream().distinct().limit(4).skip(2).map(e -> e*e).filter(e -> e%2 ==0).sorted().forEach(e -> System.out.println(e));
+    }
+
+    @Test
+    public void t3(){
+        List<String> list = Arrays.asList("i", "love", "money");
+        list.stream()
+                .map(s->s.toUpperCase())
+                .forEach(System.out::println);
+    }
+
+    @Test
+    public void t4(){
+        List<Integer> list1 = Arrays.asList(1, 2);
+        List<Integer> list2 = Arrays.asList(3, 4, 5);
+        // 1 把两个集合存入stream流中
+        Stream<List<Integer>> listStream = Stream.of(list1, list2);
+        // 2 对把两个集合转换成Stream并进行合并
+        listStream
+                .flatMap(list->list.stream())
+                .forEach(System.out::println);
+    }
+
+
+    @Test
+    public void t5(){
+        List<Integer> list = Arrays.asList(2, 3, 7, 4, 9, 1);
+        list.stream().sorted().forEach(System.out::println);
+    }
+    @Test
+    public void t6(){
+        List<Integer> list = Arrays.asList(2, 3, 7, 4, 9, 1);
+//        list.stream().sorted((o1, o2) -> o2-o1).forEach(System.out::println);
+        list.stream().sorted(Comparator.reverseOrder()).forEach(System.out::println);
+    }
+
+
+    @Test
+    public void t7(){
+        List<Integer> list = Arrays.asList(1, 2, 1, 3, -1, 2, 4);
+        //  获取流种元素的个数
+        long count = list.stream().count();
+        System.out.println(count);
+
+        //: 获取给定一个集合中的最大值
+        Optional<Integer> max = list.stream().max(Comparator.naturalOrder());
+        Integer integer = max.get();
+        System.out.println(integer);
+
+        Integer integer1 = list.stream().min(Comparator.naturalOrder()).get();
+        System.out.println(integer1);
+    }
+
+    @Test
+    public void t8(){
+        List<Integer> list = Arrays.asList(1, 2, 1, 3, 2, 4);
+        list.stream().distinct().collect(Collectors.toList());
+        list.stream().collect(Collectors.toSet());
+
+    }
+
+    @Test
+    public void t9(){
+
+        /**
+         * 需求: 把合list进行去重后收集到Map集合中，要求: 元素作为key,元素的平方作为value
+         */
+        List<Integer> list = Arrays.asList(1, 2, 1, 3, 2, 4);
+        Map<Integer, Integer> collect = list.stream().distinct().collect(Collectors.toMap(new Function<Integer, Integer>() {
+                                                                                              @Override
+                                                                                              public Integer apply(Integer integer) {
+                                                                                                  return integer;
+                                                                                              }
+                                                                                          }, new Function<Integer, Integer>() {
+                                                                                              @Override
+                                                                                              public Integer apply(Integer integer) {
+                                                                                                  return integer * integer;
+                                                                                              }
+                                                                                          }
+        ));
+        System.out.println(collect);
+
+        // 转换成lambda表达式
+        Map<Integer, Integer> collect1 = list.stream().distinct().collect(Collectors.toMap(integer -> integer, integer -> integer * integer));
+        collect1.forEach(((k,v) -> System.out.println("key = "+k +"value = "+v) ));
+    }
+
+    @Test
+    public void t10(){
+        Integer collect = Arrays.asList(1, 2, 3, 4, 5, 6, 7).stream().map(e -> e * e).collect(Collectors.summingInt(e -> e));
+        Double collect1 = Arrays.asList(1, 2, 3, 4, 5, 6, 7).stream().map(e -> e * e).collect(Collectors.summingDouble(e -> e * 1.0));
+        Double collectavg = Arrays.asList(1, 2, 3, 4, 5, 6, 7).stream().map(e -> e * e).collect(Collectors.averagingDouble(e -> e * 1.0));
+        System.out.println(collectavg);
+    }
+
+
+    /**
+     * jdbc   - 添加
+     */
+    @Test
+    public void t11() throws ClassNotFoundException, SQLException {
+        //①加载数据库驱动
+        Class.forName("com.mysql.jdbc.Driver");
+        //②创建数据库连接
+        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/jdbc?characterEncoding=utf-8", "root", "root");
+        //创建statement对象
+        Statement statement = connection.createStatement();
+        String sql = "INSERT INTO user (user_name,price,create_time) values ('zhangSan1011',100.12,now())";
+        int i = statement.executeUpdate(sql);
+        // 影响行数
+        System.out.println(i);
+    }
+
+    @Test
+    public void t12() throws ClassNotFoundException, SQLException {
+        // 1  加载数据库的驱动
+        List<User> users = new ArrayList<>();
+        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
+        Connection connection = DriverManager.getConnection("jdbc:mysql:///jdbc?characterEncoding=utf-8", "root", "root");
+        Statement statement = connection.createStatement();
+        String sql = "select  * from user";
+        ResultSet resultSet = statement.executeQuery(sql);
+        while (resultSet.next()){
+            User user = new User();
+            int user_id = resultSet.getInt("user_id");
+            String user_name = resultSet.getString("user_name");
+            double price = resultSet.getDouble("price");
+            Date create_time = resultSet.getDate("create_time");
+            user.setUserId(user_id);
+            user.setUserName(user_name);
+            user.setPrice(price);
+            user.setCreateTime(create_time);
+            users.add(user);
+        }
+        System.out.println(users);
+    }
+    //  查询单个信息  自己完成
+
+    @Test
+    public void t13() throws ClassNotFoundException, SQLException {
+        //分页查询
+        // 1  加载数据库的驱动
+        List<User> users = new ArrayList<>();
+        Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
+        Connection connection = DriverManager.getConnection("jdbc:mysql:///jdbc?characterEncoding=utf-8", "root", "root");
+        Statement statement = connection.createStatement();
+        //   10条      页大小3    第二页的数据
+        //   offset = (pageNo - 1 ) * pageSize
+        String sql = "select  * from user limit 3 ,3";
+        ResultSet resultSet = statement.executeQuery(sql);
+        while (resultSet.next()){
+            User user = new User();
+            int user_id = resultSet.getInt("user_id");
+            String user_name = resultSet.getString("user_name");
+            double price = resultSet.getDouble("price");
+            Date create_time = resultSet.getDate("create_time");
+            user.setUserId(user_id);
+            user.setUserName(user_name);
+            user.setPrice(price);
+            user.setCreateTime(create_time);
+            users.add(user);
+        }
+
+        System.out.println(users);
+
+    }
+}

src/main/java/com/sf/quanrizhi/day02/User.java

@@ -0,0 +1,62 @@
+package com.sf.quanrizhi.day02;
+
+import java.util.Date;
+
+public class User {
+    private Integer userId;
+    private String userName;
+    private Double price;
+    private Date createTime;
+
+    public User() {
+    }
+
+    public User(Integer userId, String userName, Double price, Date createTime) {
+        this.userId = userId;
+        this.userName = userName;
+        this.price = price;
+        this.createTime = createTime;
+    }
+
+    public Integer getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Integer userId) {
+        this.userId = userId;
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
+    public Double getPrice() {
+        return price;
+    }
+
+    public void setPrice(Double price) {
+        this.price = price;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    @Override
+    public String toString() {
+        return "User{" +
+                "userId=" + userId +
+                ", userName='" + userName + '\'' +
+                ", price=" + price +
+                ", createTime=" + createTime +
+                '}';
+    }
+}

src/main/resources/user.properties

@@ -1,2 +1,2 @@
-className:com.sf.quanrizhi.User
+className:com.sf.quanrizhi.day01.User
 methodName:show

target/classes/user.properties

@@ -1,2 +1,2 @@
-className:com.sf.quanrizhi.User
+className:com.sf.quanrizhi.day01.User
 methodName:show