@@ -0,0 +1,1171 @@
+import org.apache.log4j.Logger;%0A%0Aimport java.sql.Connection;%0Aimport java.sql.ResultSet;%0Aimport java.sql.SQLException;%0Aimport java.sql.Statement;%0Aimport java.sql.Types;%0Aimport java.sql.*;%0Aimport java.io.*;%0Aimport java.lang.*;%0Aimport java.util.*;%0Aimport java.util.Scanner;%0A%0Apublic class JDBCTestQuery %7B%0A%0Apublic static void main(String s%5B%5D) throws Exception %7B%0A%0A    Connection conn = null;%0A    PreparedStatement prdstmnt = null;%0A    try %7B%0A        final String URL_STRING = %22jdbc:drill:schema=dfs.tmp;drillbit=test-123%22;%0A        Class.forName(%22org.apache.drill.jdbc.Driver%22).newInstance();%0A        conn = DriverManager.getConnection(URL_STRING,%22test%22,%22test%22);%0A        prdstmnt = conn.prepareStatement(%22SELECT * FROM cp.%60employee.json%60%22);%0A        prdstmnt.executeQuery();%0A        prdstmnt.close();%0A    %7D catch (Exception e) %7B%0A       System.out.println(e.getMessage());%0A       e.printStackTrace();%0A    %7D finally %7B%0A        if(conn != null)%0A            try %7B conn.close(); %7D catch(SQLException sqlexcpn)%7B sqlexcpn.printStackTrace(); %7D%0A        if(prdstmnt != null)%0A            try %7B prdstmnt.close(); %7D catch(SQLException sqlexcpn)%7B sqlexcpn.printStackTrace(); %7D%0A        %7D%0A    %7D%0A%7D%0A

Create JDBCTestQuery.java