no message

张道锋
1 parent ba2f7301
Showing 7 changed files with 135 additions and 17 deletions Show diff stats
app/build.gradle
app/libs/processor.jar
app/src/main/assets/migrations/1.sql
app/src/main/assets/migrations/3.sql
app/src/main/java/com/shunzhi/parent/annotation/VersionTest.java
processor/src/main/java/org/shunzhi/processorlibs/Update.java
processor/src/main/java/org/shunzhi/processorlibs/VersionProcessor.java
@@ -45,7 +45,36 @@ android {
 task processorTask(type: Copy) {
     from '../processor/build/libs/processor.jar' into 'libs/'
 }
+
+//region  如果需要注释，注释掉可以合并起来的这一段全部
+task fileCheckTask() {
+    //delete('/app/src/main/assets/migrations')
+    //此方法执行以后会删除所有的version.sql文件，不能主动添加sql语句
+    //如果已经定义、实现的注解不能满足更新要求，请自己添加sql语句，并且将下面删除文件的语句注释
+    //注意 注释以后不要打开(写这个task是为了试验)
+    doLast {
+        File file = new File(rootDir.getAbsolutePath() + "\\app\\src\\main\\assets\\migrations")
+        File[] files = file.listFiles()
+        for (int i = 0; i < files.length; i++) {
+            File file1 = files[i]
+            println("delete : "+file1.getAbsolutePath())
+            file1.delete()
+        }
+    }
+}
+
+afterEvaluate {
+    tasks.matching {
+        it.name.startsWith('process') && (it.name.endsWith('ReleaseJavaRes') || it.name.endsWith
+                ('DebugJavaRes'))
+    }.each { tk ->
+        tk.dependsOn(fileCheckTask)
+    }
+}
+//endregion
+
 processorTask.dependsOn(':processor:build')
+
 preBuild.dependsOn(processorTask)
 greendao {
     schemaVersion 1//数据库版本升级
@@ -66,4 +95,4 @@ dependencies {
     compile 'me.leolin:ShortcutBadger:1.1.19@aar'
     annotationProcessor 'com.google.dagger:dagger-compiler:2.12'
     compile files('libs/processor.jar')
 -}
+}
 \ No newline at end of file
@@ -1,2 +0,0 @@
-ALTER table message add COLUMN test TEXT
-UPDATE message SET test = 'sql默认' WHERE test= NULL
@@ -0,0 +1,3 @@
+ALTER table test ADD COLUMN age INTEGER
+ALTER table test ADD COLUMN area INTEGER
+ALTER table test ADD COLUMN name TEXT
@@ -2,6 +2,11 @@ package com.shunzhi.parent.annotation;
 import org.shunzhi.processorlibs.AddColumn;
+/*
+Error:groovy.lang.MissingMethodException: No signature of method:
+java.io.File.plus() is applicable for argument types: (java.lang.String) values: [\app\src\main\assets\migrations]
+ */
+
 public class VersionTest {
     @AddColumn(version = 3, tableName = "test", type = "String")
     private String name;
@@ -0,0 +1,39 @@
+package org.shunzhi.processorlibs;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * 可能会使用到，只定义了注解，逻辑处理需要在VersionProcessor类中实现<p/>
+ * 需要使用的时候自己实现
+ */
+@Target(ElementType.FIELD)
+@Retention(RetentionPolicy.SOURCE)
+public @interface Update {
+    String columnName();
+
+    String tableName();
+
+    int version();
+
+    /**
+     * 请设置类型
+     * {@link Update#valueType()}
+     */
+    String strValue() default "";
+
+    /**
+     * 请设置类型
+     * {@link Update#valueType()}
+     */
+    int intValue() default -1;
+
+    /**
+     * 类型需要与值对应，不对应可能会导致更新数据库失败
+     */
+    String valueType();
+
+    boolean boolValue() default false;
+}
@@ -8,8 +8,11 @@ import java.io.FileWriter;
 import java.io.IOException;
 import java.io.OutputStreamWriter;
 import java.io.PrintStream;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.Locale;
 import java.util.Set;
 import javax.annotation.processing.AbstractProcessor;
@@ -31,24 +34,31 @@ public class VersionProcessor extends AbstractProcessor {
     public boolean process(Set<? extends TypeElement> annotations, RoundEnvironment roundEnv) {
 //        File file = new File("test");
 //        if (!file.exists())file.mkdir();
-//        File countFile = new File("测试数据.txt");
-//        try {
-//            BufferedWriter writer = new BufferedWriter(new FileWriter(countFile));
-//            writer.write(System.currentTimeMillis() + "");
-//            writer.newLine();
-//            writer.flush();writer.close();
-//        } catch (IOException e) {
-//            e.printStackTrace();
-//        }
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSSZ", Locale.CHINA);
+        File countFile = new File("buildData.txt");
+        BufferedWriter writer = null;
+        try {
+            writer = new BufferedWriter(new FileWriter(countFile));
+            writer.write(format.format(new Date()));
+            writer.newLine();
+            writer.flush();
+            //writer.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
         BufferedWriter testBw = null;
         HashMap<Integer, Set<String>> map = new HashMap<>();
         try {
+            File file = new File("sql.txt");
+            //if (!file.exists()) file.createNewFile();
+            Set<? extends Element> elements = roundEnv.getElementsAnnotatedWith(AddColumn.class);
+            writer.write("annotations size = " + elements.size());
             for (Element element : roundEnv.getElementsAnnotatedWith(AddColumn.class)) {
-                File file = new File("sql.txt");
-                if (!file.exists()) file.createNewFile();
+                writer.write(element.getSimpleName().toString());
+                writer.newLine();
                 testBw = new BufferedWriter(new OutputStreamWriter(new PrintStream(file)));
                 AddColumn addColumn = element.getAnnotation(AddColumn.class);
                 int version = addColumn.version();
@@ -72,6 +82,8 @@ public class VersionProcessor extends AbstractProcessor {
                     if (!isDebug)
                         set.add(sql);
                 }
+                writer.write(sql);
+                writer.newLine();
                 if (isDebug) {
                     testBw.write(version + "   ");
                     testBw.write(sql);
@@ -91,27 +103,52 @@ public class VersionProcessor extends AbstractProcessor {
             }
         }
         File tmp = new File("tmp");
-//        File migrations = new File(tmp.getParentFile(), "app\\src\\main\\assets\\migrations\\".replace("\\", File.separator));
+        File migrations = new File(tmp.getParentFile(), "app\\src\\main\\assets\\migrations\\".replace("\\", File.separator));
+        try {
+            writer.newLine();
+            writer.write(map.toString());
+            writer.newLine();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
 //        if (migrations.exists()) {
 //            File[] files = migrations.listFiles();
-//            if (files != null)
+//            if (files != null) {
 //                for (File f : files) {
 //                    try {
+//                        writer.write("exist files" + f.getName());
+//                        writer.newLine();
+//                        writer.flush();
 //                        Integer existVersion = Integer.parseInt(f.getName().replace(".sql", ""));
 //                        if (existVersion < 2) continue;
 //                        if (!map.containsKey(existVersion)) {
+//                            writer.write("delete file" + f.getName());
+//                            writer.newLine();
+//                            writer.flush();
 //                            f.delete();
 //                        }
-//                    } catch (NumberFormatException e) {
+//                    } catch (Exception e) {
 //                        e.printStackTrace();
 //                    }
 //                }
+//            }
 //        }
+
+        try {
+            writer.write("will create sql file");
+            writer.newLine();
+            writer.write(map.toString());
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
         for (Integer version : map.keySet()) {
             try {
                 String path = "app\\src\\main\\assets\\migrations\\".replace("\\", File.separator) + version + ".sql";
                 File file = new File(tmp.getParentFile(), path);
                 Set<String> set = map.get(version);
+                writer.write("create file" + version + ".sql");
+                writer.newLine();
+                writer.flush();
                 if (file.exists()) {
                     BufferedReader br = new BufferedReader(new FileReader(file));
                     String buffer;
@@ -119,6 +156,8 @@ public class VersionProcessor extends AbstractProcessor {
                         set.add(buffer);
                     }
                     br.close();
+                } else {
+                    file.createNewFile();
                 }
                 BufferedWriter bw = new BufferedWriter(new FileWriter(file));
                 StringBuilder builder = new StringBuilder();
@@ -133,6 +172,11 @@ public class VersionProcessor extends AbstractProcessor {
                 e.printStackTrace();
             }
         }
+        try {
+            writer.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
         return true;
     }
 }
 \ No newline at end of file
	@@ -45,7 +45,36 @@ android {		@@ -45,7 +45,36 @@ android {
45	task processorTask(type: Copy) {	45	task processorTask(type: Copy) {
46	from '../processor/build/libs/processor.jar' into 'libs/'	46	from '../processor/build/libs/processor.jar' into 'libs/'
47	}	47	}
		48	+
		49	+//region 如果需要注释，注释掉可以合并起来的这一段全部
		50	+task fileCheckTask() {
		51	+ //delete('/app/src/main/assets/migrations')
		52	+ //此方法执行以后会删除所有的version.sql文件，不能主动添加sql语句
		53	+ //如果已经定义、实现的注解不能满足更新要求，请自己添加sql语句，并且将下面删除文件的语句注释
		54	+ //注意注释以后不要打开(写这个task是为了试验)
		55	+ doLast {
		56	+ File file = new File(rootDir.getAbsolutePath() + "\\app\\src\\main\\assets\\migrations")
		57	+ File[] files = file.listFiles()
		58	+ for (int i = 0; i < files.length; i++) {
		59	+ File file1 = files[i]
		60	+ println("delete : "+file1.getAbsolutePath())
		61	+ file1.delete()
		62	+ }
		63	+ }
		64	+}
		65	+
		66	+afterEvaluate {
		67	+ tasks.matching {
		68	+ it.name.startsWith('process') && (it.name.endsWith('ReleaseJavaRes') \|\| it.name.endsWith
		69	+ ('DebugJavaRes'))
		70	+ }.each { tk ->
		71	+ tk.dependsOn(fileCheckTask)
		72	+ }
		73	+}
		74	+//endregion
		75	+
48	processorTask.dependsOn(':processor:build')	76	processorTask.dependsOn(':processor:build')
		77	+
49	preBuild.dependsOn(processorTask)	78	preBuild.dependsOn(processorTask)
50	greendao {	79	greendao {
51	schemaVersion 1//数据库版本升级	80	schemaVersion 1//数据库版本升级
	@@ -66,4 +95,4 @@ dependencies {		@@ -66,4 +95,4 @@ dependencies {
66	compile 'me.leolin:ShortcutBadger:1.1.19@aar'	95	compile 'me.leolin:ShortcutBadger:1.1.19@aar'
67	annotationProcessor 'com.google.dagger:dagger-compiler:2.12'	96	annotationProcessor 'com.google.dagger:dagger-compiler:2.12'
68	compile files('libs/processor.jar')	97	compile files('libs/processor.jar')
69	-}	98	-}
		99	+}
70	\ No newline at end of file	100	\ No newline at end of file
	@@ -1,2 +0,0 @@	@@ -1,2 +0,0 @@
1	-ALTER table message add COLUMN test TEXT
2	-UPDATE message SET test = 'sql默认' WHERE test= NULL
@@ -0,0 +1,3 @@		@@ -0,0 +1,3 @@
	1	+ALTER table test ADD COLUMN age INTEGER
	2	+ALTER table test ADD COLUMN area INTEGER
	3	+ALTER table test ADD COLUMN name TEXT
@@ -0,0 +1,39 @@		@@ -0,0 +1,39 @@
	1	+package org.shunzhi.processorlibs;
	2	+
	3	+import java.lang.annotation.ElementType;
	4	+import java.lang.annotation.Retention;
	5	+import java.lang.annotation.RetentionPolicy;
	6	+import java.lang.annotation.Target;
	7	+
	8	+/**
	9	+ * 可能会使用到，只定义了注解，逻辑处理需要在VersionProcessor类中实现<p/>
	10	+ * 需要使用的时候自己实现
	11	+ */
	12	+@Target(ElementType.FIELD)
	13	+@Retention(RetentionPolicy.SOURCE)
	14	+public @interface Update {
	15	+ String columnName();
	16	+
	17	+ String tableName();
	18	+
	19	+ int version();
	20	+
	21	+ /**
	22	+ * 请设置类型
	23	+ * {@link Update#valueType()}
	24	+ */
	25	+ String strValue() default "";
	26	+
	27	+ /**
	28	+ * 请设置类型
	29	+ * {@link Update#valueType()}
	30	+ */
	31	+ int intValue() default -1;
	32	+
	33	+ /**
	34	+ * 类型需要与值对应，不对应可能会导致更新数据库失败
	35	+ */
	36	+ String valueType();
	37	+
	38	+ boolean boolValue() default false;
	39	+}