Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.util.*;
- import java.io.*;
- import java.sql.*;
- public class RawData {
- private int numberOfLocs = -1;
- private int numberOfRows = -1;
- private String tablename = " Agnes1 ";
- // private String tablename = " Data ";
- // private String tablename = " Visitors ";
- //ling public String[] getNodeNames(String restriction, String classNumber, String dateRestriction) {
- public String[] getNodeNames(String restriction, int classNumber, String dateRestriction) {
- Connection C = getConnection();
- String[] names = null;
- try {
- Statement Stmt = C.createStatement(
- ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_UPDATABLE
- );
- // Stmt.executeUpdate("CREATE TEMPORARY TABLE temp (loc VARCHAR(30))");
- //ling
- Stmt.executeUpdate("CREATE TEMPORARY TABLE temp (loc VARCHAR(30))");
- //end ling
- String s = "WHERE class='" + classNumber + "'";
- if (!restriction.equals("")) {
- s += " AND student like '" + restriction + "'";
- }
- if (!dateRestriction.equals("")) {
- s += " AND timedate='" + dateRestriction + "'";
- }
- Stmt.executeUpdate("INSERT INTO temp SELECT DISTINCT fromLoc FROM Data " + s);
- // Stmt.executeUpdate(" SELECT DISTINCE loc FROM Data " + s);
- Stmt.executeUpdate("INSERT INTO temp SELECT DISTINCT toLoc FROM Data " + s);
- ResultSet RS = Stmt.executeQuery("SELECT DISTINCT loc FROM temp ORDER BY loc");
- RS.last();
- int n = RS.getRow();
- RS.beforeFirst();
- if (n < 1) return null;
- names = new String[n];
- int i = 0;
- while (RS.next()) {
- names[i++] = RS.getString("loc");
- }
- }
- catch (SQLException E) {
- System.out.println("SQLException: " + E.getMessage());
- System.out.println("SQLState: " + E.getSQLState());
- System.out.println("VendorError: " + E.getErrorCode());
- }
- return names;
- }
- public String[] getStudentNames(String restriction, int classNumber, String dateRestriction) {
- Connection C = getConnection();
- String[] names = null;
- try {
- Statement Stmt = C.createStatement(
- ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_UPDATABLE
- );
- Stmt.executeUpdate("CREATE TEMPORARY TABLE temp (student VARCHAR(30))");
- String s = "WHERE class='" + classNumber + "'";
- if (!restriction.equals("")) {
- s += " AND student like '" + restriction + "'";
- }
- if (!dateRestriction.equals("")) {
- s += " AND timedate='" + dateRestriction + "'";
- }
- Stmt.executeUpdate("INSERT INTO temp SELECT DISTINCT student FROM Data " + s);
- ResultSet RS2 = Stmt.executeQuery("SELECT DISTINCT student FROM temp ORDER BY student");
- // ResultSet RS2 = Stmt.executeQuery("SELECT distinct student FROM Data ");
- // ResultSet RS2 = Stmt.executeQuery("SELECT distinct Student FROM data " + s);
- RS2.last();
- int n = RS2.getRow();
- System.out.print("n has " + n + " students");
- RS2.beforeFirst();
- if (n < 1) return null;
- names = new String[n];
- int i = 0;
- while (RS2.next()) {
- names[i++] = RS2.getString("student");
- }
- }
- catch (SQLException E) {
- System.out.println("SQLException: " + E.getMessage());
- System.out.println("SQLState: " + E.getSQLState());
- System.out.println("VendorError: " + E.getErrorCode());
- }
- return names;
- }
- public double[][] getTransitionMatrix(int classNumber, String dateRestriction, String studentName, Hashtable invNodeNames) {
- int n = invNodeNames.size();
- double[][] matrix = new double[n][n];
- Connection C = getConnection();
- try {
- Statement Stmt = C.createStatement(
- ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_UPDATABLE
- );
- String s;
- s = "SELECT fromLoc,toLoc ";
- s += "FROM data ";
- s += "WHERE class='" + classNumber + "' ";
- s += " AND student like '" + studentName + "' ";
- s += " AND fromLoc != 'none' ";
- s += " AND toLoc != 'none' ";
- if (!dateRestriction.equals("")) {
- s += " AND timedate='" + dateRestriction + "'";
- }
- int fromLoc, toLoc;
- ResultSet RS = Stmt.executeQuery(s);
- while (RS.next()) {
- fromLoc = ((Integer)invNodeNames.get(RS.getString("fromLoc").toLowerCase())).intValue();
- toLoc = ((Integer)invNodeNames.get(RS.getString("toLoc").toLowerCase())).intValue();
- matrix[fromLoc][toLoc]++;
- }
- for (int i = 0; i < n; i++) {
- for (int j = 0; j < n; j++) {
- if (matrix[i][j] < .5) matrix[i][j] = -1;
- }
- }
- }
- catch (SQLException E) {
- System.out.println("SQLException: " + E.getMessage());
- System.out.println("SQLState: " + E.getSQLState());
- System.out.println("VendorError: " + E.getErrorCode());
- }
- return matrix;
- }
- public ResultSet query(String q) {
- ResultSet RS = null;
- Connection C = getConnection();
- try {
- Statement Stmt = C.createStatement(
- ResultSet.TYPE_SCROLL_INSENSITIVE,
- ResultSet.CONCUR_UPDATABLE
- );
- String s;
- s = "CREATE TEMPORARY TABLE temp (";
- s += "id INT, ";
- s += "class INT, ";
- s += "student VARCHAR(30), ";
- s += "purpose VARCHAR(50), ";
- s += "fromLoc VARCHAR(30), ";
- s += "toLoc VARCHAR(30)";
- s += ")";
- Stmt.executeUpdate(s);
- Stmt.executeUpdate("INSERT INTO temp " + q);
- Stmt.executeUpdate("CREATE TEMPORARY TABLE temp1 (loc VARCHAR(30))");
- Stmt.executeUpdate("INSERT INTO temp1 SELECT DISTINCT fromLoc FROM temp");
- Stmt.executeUpdate("INSERT INTO temp1 SELECT DISTINCT toLoc FROM temp");
- RS = Stmt.executeQuery("SELECT COUNT(DISTINCT loc) AS n FROM temp1");
- if (RS.next()) {
- numberOfLocs = RS.getInt("n");
- } else {
- numberOfLocs = -1;
- }
- RS = Stmt.executeQuery(q);
- RS.last();
- numberOfRows = RS.getRow();
- RS.first();
- }
- catch (SQLException E) {
- System.out.println("SQLException: " + E.getMessage());
- System.out.println("SQLState: " + E.getSQLState());
- System.out.println("VendorError: " + E.getErrorCode());
- }
- return RS;
- }
- private Connection getConnection() {
- Connection C = null;
- try {
- } catch (Exception E) {
- System.err.println("Unable to load driver.");
- E.printStackTrace();
- }
- String dbname = "pathfinderdata";
- String username = "root";
- String password = "newpass";
- try {
- //mona C = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433", "path", "path");
- String DB_URL = "jdbc:mysql://localhost:3306/pathfinderdata";
- C = DriverManager.getConnection(DB_URL, username, password);
- }
- catch (SQLException E) {
- System.out.println("SQLException: " + E.getMessage());
- System.out.println("SQLState: " + E.getSQLState());
- System.out.println("VendorError: " + E.getErrorCode());
- }
- // System.out.println("LingWang: End");
- return C;
- }
- public int getNumberOfLocs() { return numberOfLocs; }
- public int getNumberOfRows() { return numberOfRows; }
- }
- ---------------------------------
- "C:\Program Files\Java\jdk1.8.0_91\bin\java" -Didea.launcher.port=7546 "-Didea.launcher.bin.path=C:\Program Files (x86)\JetBrains\IntelliJ IDEA 2016.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_91\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_91\jre\lib\rt.jar;C:\Users\jalal\IdeaProjects\Good_PF\out\production\Good_PF;C:\Users\jalal\IdeaProjects\Good_PF\mariadb-java-client-1.4.6.jar;C:\Program Files (x86)\JetBrains\IntelliJ IDEA 2016.1.3\lib\idea_rt.jar" com.intellij.rt.execution.application.AppMain PF
- I am here
- SQLException: Table 'pathfinderdata.data' doesn't exist
- Query is : INSERT INTO temp SELECT DISTINCT fromLoc FROM Data WHERE class='1' AND student like '%' AND timedate='2002-5-02'
- SQLState: 42S02
- VendorError: 1146
- SQLException: Table 'pathfinderdata.data' doesn't exist
- Exception in thread "main" java.lang.NullPointerException
- Query is : INSERT INTO temp SELECT DISTINCT student FROM Data WHERE class='1' AND student like '%' AND timedate='2002-5-02'
- at PF.doClass(PF.java:96)
- SQLState: 42S02
- at PF.go(PF.java:86)
- VendorError: 1146
- at PF.main(PF.java:16)
- at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
- at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- at java.lang.reflect.Method.invoke(Method.java:498)
- at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
- Process finished with exit code 1
Advertisement
Add Comment
Please, Sign In to add comment