|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectfr.dyade.aaa.util.MySqlDBRepository
final class MySqlDBRepository
This class allows to use a MySQL database as repository with the NTransaction module.
The basic setup at the code to get Database code to run is the same. The additional thing when using MySQL database is:
<property name="Transaction" value="fr.dyade.aaa.util.NTransaction"/> <property name="NTRepositoryImpl" value="fr.dyade.aaa.util.MySqlDBRepository"/> <property name="DBDriver" value="org.gjt.mm.mysql.Driver"/> <property name="ConnURL" value="jdbc:mysql://hostname:3306/instance"/> <property name="DBUser" value="dbUserName"/> <property name="DBPass" value="dbPassword"/>
CLASSPATH=$CLASSPATH:$VIATOR_LIB/mysql-connector-java-5.0.5-bin.jar CLASSPATH=$CLASSPATH:$VIATOR_LIB/commons-dbcp-1.2.1.jar CLASSPATH=$CLASSPATH:$VIATOR_LIB/commons-pool-1.3.jar
JAVA_ARGS=$JAVA_ARGS" -DNTRepositoryImpl=fr.dyade.aaa.util.MySqlDBRepository -DDBDriver=org.gjt.mm.mysql.Driver -DConnURL=jdbc:mysql://hostname:3306/instance -DDBUser=dbUserName -DDBPass=dbPassword"
CREATE TABLE JoramDB (name VARCHAR(256), content longblob, primary key(name));
NTransaction
,
Repository
Field Summary | |
---|---|
private int |
baddeleted
|
(package private) java.sql.Connection |
conn
|
(package private) java.lang.String |
connurl
|
(package private) java.sql.PreparedStatement |
deleteStmt
|
(package private) java.io.File |
dir
|
(package private) java.lang.String |
driver
|
(package private) org.apache.commons.dbcp.BasicDataSource |
ds
|
(package private) java.sql.PreparedStatement |
insertStmt
|
static org.objectweb.util.monolog.api.Logger |
logger
|
private int |
nbdeleted
|
private int |
nbloaded
|
private int |
nbsaved
|
(package private) java.lang.String |
pass
|
(package private) boolean |
reconnectLoop
|
(package private) java.sql.PreparedStatement |
updateStmt
|
(package private) java.lang.String |
user
|
Constructor Summary | |
---|---|
MySqlDBRepository()
|
Method Summary | |
---|---|
void |
close()
Closes the repository. |
private void |
closeConnection()
|
void |
commit()
Commits all changes to the repository. |
void |
delete(java.lang.String dirName,
java.lang.String name)
Deletes the corresponding objects in repository. |
private java.sql.Connection |
getConnection()
|
int |
getNbBadDeletedObjects()
Returns the number of useless delete operation on repository. |
int |
getNbDeletedObjects()
Returns the number of delete operation on repository. |
int |
getNbLoadedObjects()
Returns the number of load operation from repository. |
int |
getNbSavedObjects()
Returns the number of save operation to repository. |
void |
init(java.io.File dir)
Initializes the repository. |
java.lang.String[] |
list(java.lang.String prefix)
Gets a list of persistent objects that name corresponds to prefix. |
byte[] |
load(java.lang.String dirName,
java.lang.String name)
Loads the byte array. |
java.lang.Object |
loadobj(java.lang.String dirName,
java.lang.String name)
Loads the object. |
private void |
reconnection()
|
void |
save(java.lang.String dirName,
java.lang.String name,
byte[] content)
Save the corresponding bytes array. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
java.lang.String driver
java.lang.String connurl
java.lang.String user
java.lang.String pass
org.apache.commons.dbcp.BasicDataSource ds
boolean reconnectLoop
public static org.objectweb.util.monolog.api.Logger logger
java.io.File dir
private int nbsaved
private int nbdeleted
private int baddeleted
private int nbloaded
java.sql.Connection conn
java.sql.PreparedStatement insertStmt
java.sql.PreparedStatement updateStmt
java.sql.PreparedStatement deleteStmt
Constructor Detail |
---|
MySqlDBRepository()
Method Detail |
---|
public int getNbSavedObjects()
getNbSavedObjects
in interface Repository
public int getNbDeletedObjects()
getNbDeletedObjects
in interface Repository
public int getNbBadDeletedObjects()
getNbBadDeletedObjects
in interface Repository
public int getNbLoadedObjects()
getNbLoadedObjects
in interface Repository
public void init(java.io.File dir) throws java.io.IOException
init
in interface Repository
java.io.IOException
public java.lang.String[] list(java.lang.String prefix) throws java.io.IOException
list
in interface Repository
java.io.IOException
public void save(java.lang.String dirName, java.lang.String name, byte[] content) throws java.io.IOException
save
in interface Repository
java.io.IOException
public java.lang.Object loadobj(java.lang.String dirName, java.lang.String name) throws java.io.IOException, java.lang.ClassNotFoundException
java.lang.ClassNotFoundException
java.io.IOException
public byte[] load(java.lang.String dirName, java.lang.String name) throws java.io.IOException
load
in interface Repository
java.io.IOException
public void delete(java.lang.String dirName, java.lang.String name) throws java.io.IOException
delete
in interface Repository
java.io.IOException
public void commit() throws java.io.IOException
commit
in interface Repository
java.io.IOException
public void close() throws java.io.IOException
close
in interface Repository
java.io.IOException
private java.sql.Connection getConnection() throws java.sql.SQLException
java.sql.SQLException
private void closeConnection()
private void reconnection() throws java.io.IOException
java.io.IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |