edu.ogi.cse.xs.database.mysql
Class MySQLConnection

java.lang.Object
  edu.ogi.cse.xs.database.mysql.MySQLConnection

All Implemented Interfaces:

DBConnection

public class MySQLConnection
extends java.lang.Object
implements DBConnection

Constructor Summary

MySQLConnection(java.lang.String connName, java.lang.String driver, java.lang.String url, java.lang.String username, java.lang.String passwd)

Method Summary

void	close()
java.lang.String	dumpBulkLoadCmd(RelationalSchema relschema, java.lang.String datadir)
java.sql.ResultSet	executeQuery(java.lang.String query)
void	genRelationalSchema(RelationalSchema relschema, java.lang.String sqlpath)
java.lang.String	getName()
java.lang.String[]	getTableNames()
void	insertRow(java.lang.String tableName, java.lang.String[] values, int[] sqltype)
void	performBulkloading(java.lang.String cmdPath)
void	writeRow(java.lang.String[] values, java.io.PrintWriter pw)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySQLConnection

public MySQLConnection(java.lang.String connName,
                       java.lang.String driver,
                       java.lang.String url,
                       java.lang.String username,
                       java.lang.String passwd)

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface DBConnection

close

public void close()

Specified by:

close in interface DBConnection

genRelationalSchema

public void genRelationalSchema(RelationalSchema relschema,
                                java.lang.String sqlpath)

Specified by:

genRelationalSchema in interface DBConnection

insertRow

public void insertRow(java.lang.String tableName,
                      java.lang.String[] values,
                      int[] sqltype)

Specified by:

insertRow in interface DBConnection

writeRow

public void writeRow(java.lang.String[] values,
                     java.io.PrintWriter pw)

Specified by:

writeRow in interface DBConnection

dumpBulkLoadCmd

public java.lang.String dumpBulkLoadCmd(RelationalSchema relschema,
                                        java.lang.String datadir)

Specified by:

dumpBulkLoadCmd in interface DBConnection

performBulkloading

public void performBulkloading(java.lang.String cmdPath)

Specified by:

performBulkloading in interface DBConnection

getTableNames

public java.lang.String[] getTableNames()

Specified by:

getTableNames in interface DBConnection

executeQuery

public java.sql.ResultSet executeQuery(java.lang.String query)

Specified by:

executeQuery in interface DBConnection