How to save a Message object as a blob in Oracle database.

[Akhil gupta]

Hi

I need to save a Message object read from a mailbox as a blob in Oracle database. While doing so I am getting the NotSerializableException, which I understand is because the Message class does not implement the Serializable interface.
Can anyone tell me how to save it? I have written the following code:

DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
conn=DriverManager.getConnection("jdbc :-o	 racle:thin:@funscool:1521:fixapp", "usr_name", "pwd");
conn.setAutoCommit(false);
String strQuery="Insert into CM_TB(CONTACTMEDIUMID,CMCONTENTS) values (?,empty_blob())";
psInsert=conn.prepareStatement(strQuery);
psInsert.setInt(1, iMessageId);
int iRowCount = psInsert.executeUpdate();
System.out.println("iRowCount: "+iRowCount);
String strSelect="Select CMCONTENTS FROM CM_TB where contactmediumid=? for update";
psSelect=conn.prepareStatement(strSelect);
psSelect.setInt(1,iMessageId);
rs=psSelect.executeQuery();
if(rs.next())
{
blob=((OracleResultSet)rs).getBLOB(1);
outStream = blob.getBinaryOutputStream();
objOutStream = new ObjectOutputStream (outStream);
objOutStream.writeObject(objMailMessage);
objOutStream.close();
}
 

[J Kneeland]

You would have to extract the data and write the data instead of he object.

[Julian Kennedy]

Hi AkhilGupta Gupta,

My first reaction was to say "wrap it in something that does" but, on reflection, that may be a little naive. I've not checked a spec or anything but I imagine it may be necessary for all members to be serializable, so that wouldn't help.

The other alternative is to define a SerializableMessage class and copy the state of your Message to an instance of it for serialization, then do the reverse after deserialization.

Maybe there are more elegant methods, but that's my best attempt.

Jules

[Akhil gupta]

Thanks Guys

Following piece of code has worked for me.

DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
conn=DriverManager.getConnection("jdbc :-o	 racle:thin:@funscool:1521:fixapp", "usr_name", "pwd");
conn.setAutoCommit(false);
String strQuery="Insert into CM_TB(CONTACTMEDIUMID,CMCONTENTS) values (?,empty_blob())";
psInsert=conn.prepareStatement(strQuery);
psInsert.setInt(1, iMessageId);
int iRowCount = psInsert.executeUpdate();
String strSelect="Select CMCONTENTS FROM CM_TB where contactmediumid=? for update";
psSelect=conn.prepareStatement(strSelect);
psSelect.setInt(1,iMessageId);
rs=psSelect.executeQuery();
if(rs.next())
{
blob=((OracleResultSet)rs).getBLOB(1);
outStream = blob.getBinaryOutputStream();
objMailMessage.writeTo(outStream);
outStream.close();
}

[Dirk Schreckmann]

Akhil_gupta01,

Welcome to JavaRanch!

We ain't got many rules 'round these parts, but we do got one. Please change your display name to comply with The JavaRanch Naming Policy.

We request that display names be of the pattern FIRST_NAME + SPACE + LAST_NAME.

Thanks Pardner! Hope to see you 'round the Ranch!