// todo: hotwire programs only once

!636

!sf

!L<S>

!cast

!class _javax 19

!JavaTok

main {

  static new Map<S, List> tables;

  static new Map<S, List> tableFields;

  static long totalRows;

  static Object in;

  static Class x1000656;

  static Object releaseNote = new Object() { public void finalize() {

    System.err.println("Note: MySQL dump importer released.");

  }};

  psvm {

    if (in == null)

      in = loadSnippet("#3000013"); // mysql dump

    // load subprograms

    x1000656 = hotwire("#1000656");

    L<S> creates = find_create_statements((S) in);

    print(creates.size() + " creates");

    for (S create : creates) {

      String tableName = get_table_name_from_create_statement(create);

      String[] names = find_field_names(create).split(", ");

      tableFields.put(tableName, Arrays.asList(names));

    }

    L<S> inserts = find_insert_statements((S) in);

    print(inserts.size() + " inserts");

    for (S insert : inserts) {

      String table = get_table_name_from_insert_statement(insert);

      print("Getting values");

      List data = parse_mysql_values(insert);

      print("Got values (" + data.size() + " rows)");

      addData(table, data);

      totalRows += data.size();

    }

    print("Tables: " + structure(tables.keySet()));

    print("Fields: " + structure(tableFields));

    print("Total rows imported: " + totalRows);

  }

  static S get_table_name_from_create_statement(S create) {

    print(create);

    // Java code taken from ?

    O in = javaTok(create);

    in = ((List) in).get(7);

    return (S) in;

  }

  static S get_table_name_from_insert_statement(S insert) {

    // Java code taken from #1000665

    O in = javaTok(insert);

    in = ((List) in).get(7);

    return (S) in;

  }

  static S find_field_names(String create) {

    return (S) process("#1000648", create);

  }

  static L<S> find_create_statements(String mysqlDump) {

    //return (L<S>) process("#1000642", mysqlDump, "markedStrings");

    return find_statements(mysqlDump, "create");

  }

  static L<S> find_insert_statements(String mysqlDump) {

    //return (L<S>) process("#1000650", mysqlDump, "markedStrings");

    return find_statements(mysqlDump, "insert");

  }

  static L<S> find_statements(String mysqlDump, String cmd) {

    new L<S> l;

    L<S> tok = mysqlTok(mysqlDump);

    int c = 0;

    for (int i = 1; i < tok.size(); i += 2) {

      S t = tok.get(i);

      if (t.equalsIgnoreCase(cmd)) {

        print("create at " + i);

        c = i;

      }

      if (t.equals(";")) {

        //print("; at " + i);

        if (c != 0) {

          l.add(JavaTok.join(tok.subList(c, i+1)));

          c = 0;

        }

      }

    }

    return l;

  }

  static L parse_mysql_values(S insert) {

    // It prints all the data if we don't silence it...

    return (L) processSilent(x1000656, insert);

  }

  static void addData(S table, List data) {

    List t = tables.get(table);

    if (t == null)

      tables.put(table, t = new List);

    t.addAll(data);

  }

}