fr.dyade.aaa.util.MySqlDBRepository

fr.dyade.aaa.util.MySqlDBRepository Class Reference

Inheritance diagram for fr.dyade.aaa.util.MySqlDBRepository:

[legend]Collaboration diagram for fr.dyade.aaa.util.MySqlDBRepository:


Public Member Functions
int	getNbSavedObjects ()
int	getNbDeletedObjects ()
int	getNbBadDeletedObjects ()
int	getNbLoadedObjects ()
void	init (File dir) throws IOException
String[]	list (String prefix) throws IOException
void	save (String dirName, String name, byte[] content) throws IOException
Object	loadobj (String dirName, String name) throws IOException, ClassNotFoundException
byte[]	load (String dirName, String name) throws IOException
void	delete (String dirName, String name) throws IOException
void	commit () throws IOException
void	close () throws IOException
Static Public Attributes
static Logger	logger
Package Functions
	MySqlDBRepository ()
Package Attributes
String	driver = System.getProperty("DBDriver", "org.gjt.mm.mysql.Driver")
String	connurl = System.getProperty("ConnURL", "jdbc:mysql://localhost:3306/mysql")
String	user = System.getProperty("DBUser", "root")
String	pass = System.getProperty("DBPass", "")
BasicDataSource	ds = null
boolean	reconnectLoop = false
File	dir = null
Connection	conn = null
PreparedStatement	insertStmt = null
PreparedStatement	updateStmt = null
PreparedStatement	deleteStmt = null

Detailed Description

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:

For the a3servers.xml that will be copy to run directory, we have to add these:

   <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"/>

In the start script in the bin directory:

We have to add the following library

 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

change the java command to add in a few -D parameter

 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"

may need to up size the max memory for better performace This is what we use: JAVA_ARGS=" -Xms100M -Xmx1024M "

At the MySQL database side:
1. we have to set the max-allowed-packet to a bigger size, I think the default is 1M, if the number of messages become large, it will fail. "max_allowed_packet=16M"
2. create the JoramDB table first (we decided that we will create it outside here instead of in the code.
```
 CREATE TABLE JoramDB (name VARCHAR(256), content longblob, primary key(name));
 
```
See also:
NTransaction
Repository