Skip to content

Commit

Permalink
added some files
Browse files Browse the repository at this point in the history
  • Loading branch information
Greg Kellum committed Mar 23, 2010
1 parent b84dbce commit a8b76cc
Show file tree
Hide file tree
Showing 7 changed files with 10,863 additions and 87 deletions.
1 change: 1 addition & 0 deletions java/buildAndPackage.sh
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
mkdir classes
javac -sourcepath src -d classes -cp lib/hsqldb.jar:lib/jsontools-core-1.7.jar:lib/antlr-3.2.jar src/Main.java src/TestDB.java
cp data/track_list.json classes
jar cf main.jar -C classes .
mv main.jar lib

Expand Down
10,708 changes: 10,708 additions & 0 deletions java/data/track_list.json
View file

Large diffs are not rendered by default.

1 change: 1 addition & 0 deletions java/data/track_list.txt
View file

Large diffs are not rendered by default.

Binary file modified java/lib/main.jar
View file
Binary file not shown.
9 changes: 2 additions & 7 deletions java/src/Main.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,21 +42,16 @@ static public String post(String actionName, String jsonEncodedArguments, String
long recordedTime = System.currentTimeMillis();

int numberOfResults = endInt - startInt;
String[] results = TestDB.query("SELECT * FROM tracks OFFSET " + startInt + " LIMIT " + numberOfResults);
String results = TestDB.getTracks(startInt, numberOfResults);

System.out.println("query speed <" + (System.currentTimeMillis() - recordedTime) + ">" );

final JSONArray jsonArray = new JSONArray();
for (String result : results) {
jsonArray.getValue().add(new JSONString(result));
}
//System.out.println("time creating json array: " + (System.currentTimeMillis() - recordedTime));
recordedTime = System.currentTimeMillis();
String renderedJSONString = jsonArray.render(true);
//System.out.println("time rendering json array: " + (System.currentTimeMillis() - recordedTime));
//System.out.println(renderedJSONString);

return renderedJSONString;
return results;
} catch (TokenStreamException e) {
// TODO Auto-generated catch block
e.printStackTrace();
Expand Down
231 changes: 151 additions & 80 deletions java/src/TestDB.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,29 +3,70 @@
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.io.*;
import com.sdicons.json.model.*;
import com.sdicons.json.parser.JSONParser;

public class TestDB {
private static Connection conn;
private static Connection conn;
private static TestDB db = null;

public TestDB(String db_file_name_prefix) throws Exception { // note more
Class.forName("org.hsqldb.jdbcDriver");
conn = DriverManager.getConnection(
"jdbc:hsqldb:" + db_file_name_prefix, "sa", "");
}
public TestDB(String db_file_name_prefix) throws Exception { // note more
Class.forName("org.hsqldb.jdbcDriver");
conn = DriverManager.getConnection(
"jdbc:hsqldb:" + db_file_name_prefix, "sa", "");
}

public static void init() {
try {
db = new TestDB("db_file");
db = new TestDB("db/library");
db.createDBIfNeeded();
} catch (Exception ignored) {
}
}

public void createDBIfNeeded() {
public void insertTracksFromJSON(TestDB db) {
String sql = "INSERT INTO tracks (track, artist, album) VALUES (?,?,?)";

try
{
PreparedStatement stmt = conn.prepareStatement(sql);

Reader fileReader = new InputStreamReader(TestDB.class.getResourceAsStream("track_list.json"));
JSONParser p = new JSONParser(fileReader);
JSONValue all = p.nextValue();
JSONObject outerBrackets = (JSONObject) all;
JSONArray tracksArray = (JSONArray) outerBrackets.getValue().get("tracks");
for (int counter = 0; counter < tracksArray.size(); counter++)
{
JSONArray trackArray = (JSONArray) tracksArray.get(counter);
assert trackArray.size() == 3;

String track = ((JSONString) trackArray.get(0)).getValue();
String artist = ((JSONString) trackArray.get(1)).getValue();
String album = ((JSONString) trackArray.get(2)).getValue();

stmt.setString(1, track);
stmt.setString(2, artist);
stmt.setString(3, album);

stmt.executeUpdate();
}

stmt.close();
}
catch (Exception exc)
{
exc.printStackTrace();
System.out.println("Error executing sql <" + sql + ">");
}
}

public void createDBIfNeeded() {
try {
Statement dummyQuery = conn.createStatement();
dummyQuery.execute("SELECT COUNT(*) FROM tracks");
Expand All @@ -35,103 +76,133 @@ public void createDBIfNeeded() {
}
}

public void createDB() {
public void createDB() {

long recordTime = System.currentTimeMillis();
try {
db = new TestDB("db_file");

//db.update("drop index filename_index");
try
{
db.update("drop table tracks");
}
catch(Exception exc) {}

db.update("CREATE TABLE tracks ( id INTEGER IDENTITY, name VARCHAR(256))");
db.update("CREATE TABLE tracks ( id INTEGER IDENTITY, track VARCHAR(256), artist VARCHAR(256), album VARCHAR(256))");
//db.update("CREATE INDEX filename_index ON tracks (name)");
System.out.println("create time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
insertData(db);
insertTracksFromJSON(db);
System.out.println("insert time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

public static void main(String[] args) throws Exception {
TestDB db = null;
db = new TestDB("db_file");
long recordTime = System.currentTimeMillis();
db.update("drop table tracks");
System.out.println("drop time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.update("CREATE TABLE tracks ( id INTEGER IDENTITY, name VARCHAR(256))");
System.out.println("create time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
insertData(db);
System.out.println("insert time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.query("SELECT * FROM tracks order by name");
System.out.println("query time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.shutdown();
System.out.println("shutdown time: " + (System.currentTimeMillis() - recordTime));
}
public static void main(String[] args) throws Exception {
TestDB db = null;
db = new TestDB("db_file");
long recordTime = System.currentTimeMillis();
db.update("drop table tracks");
System.out.println("drop time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.update("CREATE TABLE tracks ( id INTEGER IDENTITY, name VARCHAR(256))");
System.out.println("create time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
insertData(db);
System.out.println("insert time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.query("SELECT * FROM tracks order by name");
System.out.println("query time: " + (System.currentTimeMillis() - recordTime));
recordTime = System.currentTimeMillis();
db.shutdown();
System.out.println("shutdown time: " + (System.currentTimeMillis() - recordTime));
}

private static void insertData(TestDB db) throws SQLException {
int index = 0;
while (index < 100000) {
String name = "file" + index++;
db.update("INSERT INTO tracks(name) VALUES('" + name + "')");
}
}

private static void insertData(TestDB db) throws SQLException {
int index = 0;
while (index < 100000) {
String name = "file" + index++;
db.update("INSERT INTO tracks(name) VALUES('" + name + "')");
}
}
public void shutdown() throws SQLException {
Statement st = conn.createStatement();
st.execute("SHUTDOWN");
conn.close();
}

public void shutdown() throws SQLException {
Statement st = conn.createStatement();
st.execute("SHUTDOWN");
conn.close();
}
public synchronized static String[] query(String expression) throws SQLException {
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery(expression);
List<String> resultList = new ArrayList<String>();
//dump(rs);
while (rs.next()) {
long id = rs.getLong(1);
String name = rs.getString(2);
resultList.add(name);
}
st.close();

return resultList.toArray(new String[resultList.size()]);
}

public synchronized static String[] query(String expression) throws SQLException {
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery(expression);
List<String> resultList = new ArrayList<String>();
//dump(rs);
while (rs.next()) {
long id = rs.getLong(1);
String name = rs.getString(2);
resultList.add(name);
}
st.close();

return resultList.toArray(new String[resultList.size()]);
}
public synchronized static String getTracks(int startRow, int numberOfResults) throws SQLException {
StringBuffer resultBuffer = new StringBuffer("[");
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery("SELECT * FROM tracks OFFSET " + startRow + " LIMIT " + numberOfResults);
List<String> resultList = new ArrayList<String>();
//dump(rs);
boolean firstRun = true;

while (rs.next()) {
if (!firstRun) {
resultBuffer.append(",");
} else {
firstRun = false;
}

long id = rs.getLong(1);
String track = rs.getString("track");
String artist = rs.getString("artist");
String album = rs.getString("album");
resultBuffer.append("{").append("\"track\":\"").append(track).append("\",")
.append("\"artist\":\"").append(artist).append("\",")
.append("\"album\":\"").append(album).append("\"")
.append("}");
}

resultBuffer.append("]");

st.close();

return resultBuffer.toString();
}

public synchronized void update(String expression) throws SQLException {
Statement st = conn.createStatement();
int i = st.executeUpdate(expression);
public synchronized void update(String expression) throws SQLException {
Statement st = conn.createStatement();
int i = st.executeUpdate(expression);

if (i == -1) {
System.out.println("db error : " + expression);
}
st.close();
}
if (i == -1) {
System.out.println("db error : " + expression);
}
st.close();
}

public static void dump(ResultSet rs) throws SQLException {
ResultSetMetaData meta = rs.getMetaData();
int colmax = meta.getColumnCount();
int i;
Object o = null;
for (; rs.next();) {
for (i = 0; i < colmax; ++i) {
o = rs.getObject(i + 1);
System.out.print(o.toString() + " ");
}
System.out.println(" ");
}
}
public static void dump(ResultSet rs) throws SQLException {
ResultSetMetaData meta = rs.getMetaData();
int colmax = meta.getColumnCount();
int i;
Object o = null;
for (; rs.next();) {
for (i = 0; i < colmax; ++i) {
o = rs.getObject(i + 1);
System.out.print(o.toString() + " ");
}
System.out.println(" ");
}
}

}
Binary file modified musickit.app/Contents/MacOS/musickit
View file
Binary file not shown.

0 comments on commit a8b76cc

Please sign in to comment.