测试代码，编译报错解决

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/sink/PKMySQLSink.java

 package com.zhht.irn.sink;
 
-import com.imooc.flink.utils.MySQLUtils;
+import com.zhht.irn.utils.MySQLUtils;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/sink/SinkApp.java

 package com.zhht.irn.sink;
 
-import com.imooc.flink.transformation.Access;
+import com.zhht.irn.transformation.Access;
 import org.apache.flink.api.common.functions.MapFunction;
 import org.apache.flink.api.java.functions.KeySelector;
 import org.apache.flink.api.java.tuple.Tuple2;

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/source/AccessSourceV2.java

 package com.zhht.irn.source;
 
-import com.imooc.flink.transformation.Access;
+import com.zhht.irn.transformation.Access;
 import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction;
 
 import java.util.Random;

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/source/SourceApp.java

 package com.zhht.irn.source;
 
-import com.imooc.flink.transformation.Access;
+import com.zhht.irn.transformation.Access;
 import org.apache.flink.api.common.functions.FilterFunction;
 import org.apache.flink.api.common.serialization.SimpleStringSchema;
 import org.apache.flink.streaming.api.datastream.DataStream;

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/source/StudentSource.java

 package com.zhht.irn.source;
 
-import com.imooc.flink.utils.MySQLUtils;
+import com.zhht.irn.utils.MySQLUtils;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.functions.source.RichSourceFunction;
 

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/transformation/TransformationApp.java

 package com.zhht.irn.transformation;
 
-import com.imooc.flink.source.AccessSource;
+import com.zhht.irn.source.AccessSource;
 import org.apache.flink.api.common.functions.FilterFunction;
 import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.api.common.functions.MapFunction;

realtime/holographic-intersection-realtime/src/main/java/com/zhht/irn/utils/MySQLUtils.java

+package com.zhht.irn.utils;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class MySQLUtils {
+
+    public static Connection getConnection() {
+
+        try {
+            Class.forName("com.mysql.jdbc.Driver");
+            return DriverManager.getConnection("jdbc:mysql://127.0.0.1:13305/test", "root", "mima");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+
+    public static void close(Connection connection, PreparedStatement pstmt) {
+        if(null != pstmt) {
+            try {
+                pstmt.close();
+            } catch (SQLException e) {
+                e.printStackTrace();
+            }
+        }
+
+        if(null != connection) {
+            try {
+                connection.close();
+            } catch (SQLException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    public static void main(String[] args) {
+        System.out.println(getConnection());
+    }
+}