[not null][flinkStreamSQL支持not null 语法][17872]

Author: jiemotongxue

core/src/main/java/com/dtstack/flink/sql/table/AbsSourceParser.java

@@ -42,7 +42,7 @@ public abstract class AbsSourceParser extends AbsTableParser {
 
     private static Pattern virtualFieldKeyPattern = Pattern.compile("(?i)^(\\S+\\([^\\)]+\\))\\s+AS\\s+(\\w+)$");
     private static Pattern waterMarkKeyPattern = Pattern.compile("(?i)^\\s*WATERMARK\\s+FOR\\s+(\\S+)\\s+AS\\s+withOffset\\(\\s*(\\S+)\\s*,\\s*(\\d+)\\s*\\)$");
-    private static Pattern notNullKeyPattern = Pattern.compile("(?i)(\\w+)\\s+(\\w+)\\s+NOT\\s+NULL?$");
+    private static Pattern notNullKeyPattern = Pattern.compile("(?i)^(\\w+)\\s+(\\w+)\\s+NOT\\s+NULL?$");
 
     static {
         keyPatternMap.put(VIRTUAL_KEY, virtualFieldKeyPattern);

launcher/job/kafkaNotNull.txt

@@ -1,6 +1,6 @@
 CREATE TABLE MyTable(
-    channel varchar not null,
-    pv INT,
+    channel varchar as sss not null,
+    pv INT not null,
     xctime bigint,
     CHARACTER_LENGTH(channel) as timeLeng,
     WATERMARK FOR xctime AS withOffset(xctime,1000)