No change except no rows found is not reported.
package com.pop3gateway;
import com.pop3gateway.MessageObject.*;
import java.util.HashMap;
import java.util.*;
import java.io.Serializable;
import java.io.*;
import java.sql.*;
/**
* <p>Title: Extensible Messaging Platform</p>
* <p>Description: Enterprise Anti-spam Filter</p>
* <p>Copyright: Copyright (c)1997-2004</p>
* <p>Company: J.A. Korsmeyer, Inc.</p>
* @author J.A. Korsmeyer, Inc.
* @version 5.5
*/
public class Quarantine extends DatabaseServer {
//static final long serialVersionUID = -3537385394408850867L;
//protected QuarantineRec QuarantineRec = null;
protected boolean hit = false;
protected boolean success = true;
File messageFile = null;
File messageFile2 = null;
PreparedStatement stQuerySenderRecipient = null;
PreparedStatement stQuerySender = null;
PreparedStatement stQueryRecipient = null;
PreparedStatement stQueryRecipientLike = null;
PreparedStatement stInsertRec = null;
PreparedStatement stDeleteRec = null;
String quarantine = System.getProperty("EMP.home") +
File.separatorChar +
"Data"
+ File.separatorChar + "RouterProcessorEngines" +
File.separatorChar
+ "0" + File.separatorChar + "Quarantine";
String msgObjs = System.getProperty("EMP.home") + File.separatorChar +
"Data"
+ File.separatorChar + "RouterProcessorEngines" +
File.separatorChar
+ "0" + File.separatorChar + "MessageObjects";
public Quarantine() {
this(System.getProperty("EMP.home") + File.separatorChar + "Db");
System.out.println("we ran the beans constructor");
//super();
}
public Quarantine(String databaseDir) {
super(databaseDir);
System.out.println("We're ready to test if Quarantine tables
exist");
if(!quarantineTablesExist()) {
//System.out.println("They don't so create");
try {
Statement createTableStatement = dbConnection.createStatement();
System.err.println("create table statement");
Statement createIE1Statement = dbConnection.createStatement();
Statement createIE2Statement = dbConnection.createStatement();
System.err.println("create table");
createTableStatement.execute("CREATE CACHED TABLE
quarantine(FILENAME CHAR(64), SENDER CHAR(128), RECIPIENT CHAR(128),
SUBJECT CHAR(128), FILTEREDBY CHAR(24), MATCHTEXT CHAR(128), CONSTRAINT
cQuarPRI PRIMARY KEY (FILENAME))");
createIE1Statement.execute("CREATE INDEX IEQ1 ON
quarantine(SENDER)");
createIE2Statement.execute("CREATE INDEX IEQ2 ON
quarantine(RECIPIENT)");
}
catch (SQLException sqlCreateQuarantineE) {
System.err.println("ERROR: unable to create table quarantine");
sqlCreateQuarantineE.printStackTrace();
}
}
// prepare statements for later use
initQuarantine();
}
private String test = "beginning value";
private Object sheetState;
private ResultSet rslt = null;
boolean more = false;
String returnSender = null;
File dbDirPath = null;
QuarantineRec quarantineRec = null;
public void initQuarantine() {
dbDirPath = new File(System.getProperty("EMP.home") +
File.separatorChar + "Db");
//System.out.println("just entered init");
quarantineRec = new QuarantineRec();
try {
setDatabaseDir(dbDirPath.getCanonicalPath());
dbConnect();
stQuerySenderRecipient = dbConnection.prepareStatement(
"SELECT * FROM quarantine WHERE sender=? AND recipient=?",
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
//System.out.println("just prepared stQuerySenderRecipient");
stQuerySender = dbConnection.prepareStatement(
"SELECT * FROM quarantine WHERE sender=?",
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
//System.out.println("just prepared stQuerySender");
stQueryRecipient = dbConnection.prepareStatement(
"SELECT * FROM quarantine WHERE recipient=?",
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
stQueryRecipientLike = dbConnection.prepareStatement(
"SELECT * FROM quarantine WHERE recipient LIKE ?",
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
//System.out.println("just prepared stQueryRecipient");
stInsertRec = dbConnection.prepareStatement("INSERT INTO
quarantine VALUES(?,?,?,?,?,?)");
stDeleteRec = dbConnection.prepareStatement("DELETE FROM
quarantine WHERE filename = ?");
messagesList("[EMAIL PROTECTED]");
System.out.println("just called messagesList()");
} catch (SQLException stmtPrepE) {
System.err.println("ERROR: Couldn't prepare statements");
}
catch ( IOException dbPathE ) {
System.err.println("ERROR: Couldn't find path to DB directory");
}
}
public boolean quarantined(String sender, String recipient) {
hit = false;
if( sender != null && recipient != null ) {
try {
stQuerySenderRecipient.setString(1,
deFocus(sender).toLowerCase());
stQuerySenderRecipient.setString(2, recipient.toLowerCase());
rslt = stQuerySenderRecipient.executeQuery();
if (rslt != null && rslt.next()) {
hit = true;
}
}
catch (SQLException queryE) {}
}
return hit;
}
public boolean quarantined(SMTPMessageObject mo) {
hit = false;
if (mo.getSender() != null) {
try {
stQuerySender.setString(1,
deFocus(mo.getSender().toLowerCase()));
//System.out.println("getSender= " + deFocus(mo.getSender()));
//System.out.println("recipientsString= " +
mo.getRecipientsAsString());
rslt = stQuerySender.executeQuery();
if (rslt != null) more = rslt.next();
while (more && rslt != null) {
//System.out.println("recipient=" + rslt.getString(2));
//System.out.println("recipString=" +
mo.getRecipientsAsString());
if
(mo.getRecipientsAsString().toLowerCase().indexOf(rslt.getString(2).
toLowerCase()) > -1) {
//System.out.println("matched");
hit = true;
break;
}
more = rslt.next();
}
}
catch (SQLException queryE) {}
}
return hit;
}
public void messagesList(String recipient) {
if( recipient != null ) {
try {
stQueryRecipientLike.setString(1, "%" + recipient.toLowerCase()
+ "%");
rslt = stQueryRecipientLike.executeQuery();
System.out.println("result set=" + rslt);
if(rslt.last()) {
System.out.println("Number of records: " + rslt.getRow());
} else {
System.out.println("No records returned");
}
} catch (SQLException queryE) { queryE.printStackTrace(); }
}
}
boolean tryAgain = true;
public QuarantineRec getNextRec() {
tryAgain = true;
try {
if( rslt != null && rslt.next() ) {
while(tryAgain) {
messageFile = new File(quarantine + File.separatorChar +
rslt.getString("FILENAME"));
if (messageFile.exists()) {
//System.out.println("sender=" + rslt.getString(1));
quarantineRec.filename = rslt.getString("FILENAME");
quarantineRec.sender = rslt.getString("SENDER");
quarantineRec.recipient =
truncate(rslt.getString("RECIPIENT"), 64);
quarantineRec.subject = truncate(rslt.getString("SUBJECT"),
64);
quarantineRec.filteredby = rslt.getString("FILTEREDBY");
quarantineRec.matchtext =
truncate(rslt.getString("MATCHTEXT"), 64);
tryAgain = false;
}
else {
deleteRec(rslt.getString("FILENAME")); // cleanup database
record for deleted message
if(! rslt.next()) { break; }
}
}
}
else {
return null;
}
}catch (SQLException getNextE) {}
return quarantineRec;
}
public String displayMessage(String filename) {
String messageText = null;
String tempLine;
int lineNum = 0;
try {
BufferedReader bufMessageReader = new BufferedReader(new
FileReader(quarantine + File.separatorChar + filename));
while( (tempLine = bufMessageReader.readLine()) != null ) {
//System.out.println("(" + tempLine + ")");
messageText += tempLine + "\n";
lineNum++;
if(lineNum > 100) { break; }
}
bufMessageReader.close();
}
catch( Exception e) {
e.printStackTrace();
}
return messageText;
}
public boolean insertRec(String filename, String sender, String
recipient, String subject, String filteredby, String matchtext) {
success = false;
if( sender != null && recipient != null ) {
try {
success = true;
stInsertRec.setString(1, filename);
stInsertRec.setString(2, deFocus(sender.toLowerCase()));
stInsertRec.setString(3, recipient.toLowerCase());
stInsertRec.setString(4, subject);
stInsertRec.setString(5, filteredby);
stInsertRec.setString(6, matchtext);
stInsertRec.execute();
}
catch (SQLException insertE) {}
}
return success;
}
public boolean deleteRec(String filename) {
try {
success = true;
stDeleteRec.setString(1, filename);
stDeleteRec.execute();
// Delete from Quarantine directory
messageFile = new File(quarantine + File.separatorChar +
filename);
if(messageFile.exists()) {
messageFile.delete();
}
} catch(SQLException deleteE) { success = false; }
return success;
}
public boolean deliver(String filename) {
boolean success = true;
try {
stDeleteRec.setString(1, filename);
stDeleteRec.execute();
messageFile = new File(quarantine + File.separatorChar +
filename);
messageFile2 = new File(msgObjs + File.separatorChar + filename);
messageFile.renameTo(messageFile2);
} catch(SQLException deleteE) { success = false; }
return success;
}
public boolean messageFileExists(String filename) {
boolean exists = false;
messageFile = new File(quarantine + File.separatorChar + filename);
if(messageFile.exists()) { exists = true; }
return exists;
}
protected boolean quarantineTablesExist() {
boolean exists = true;
// String[] types = {"TABLE"};
try {
Statement statement = dbConnection.createStatement();
ResultSet rs = statement.executeQuery("SELECT * FROM quarantine");
/*
DatabaseMetaData metaData = dbConnection.getMetaData();
ResultSet rs = metaData.getTables(null, null, "whitelist", // 2nd
null would be schemapattern
null);
if(rs.next()) { //the table exists
exists = true;
}
*/
}catch (Exception e) { e.printStackTrace(); exists = false; }
return exists;
}
public void quarantineDirectoryCleanup() {
// Delete from database if not in Quarantine directory
//
}
public void close() {
try {
dbConnection.commit();
dbConnection.close();
} catch (SQLException sqlClose) {
System.err.println("ERROR: closing connection into
statistics database");
sqlClose.printStackTrace();
}
}
protected String deFocus(String str) {
String returnToken = ""; // probably should be null but we need to
fix in full path (SMTPmsgObject + output portal
StringTokenizer tokenizer = new StringTokenizer(str, "<>");
if( tokenizer.hasMoreTokens()) {
returnToken = tokenizer.nextToken();
}
return returnToken;
}
public String truncate(String string, int maxChars) {
String returnString = string;
if(string != null && string.length() > maxChars) {
returnString = string.substring(0, maxChars);
}
return returnString;
}
public ResultSet getRslt() {
System.out.println("just called getRslt()");
return rslt;
}
public void setRslt(ResultSet rslt) { this.rslt = rslt; }
//void getInitQuarantine() { initQuarantine(); }
//void setInitQuarantine() { initQuarantine(); }
public Object getSheetState() {
return sheetState;
}
public void setSheetState(Object sheetState) {
this.sheetState = sheetState;
}
public void setTest(String teststring) {
this.test = teststring;
System.out.println("just setTest to " + this.test);
this.test = "this is what we hard setTest to";
}
public String getTest() { return this.test; }
}
-----Original Message-----
From: Bernd Bohmann [mailto:[EMAIL PROTECTED]
Sent: Monday, March 06, 2006 11:27 AM
To: MyFaces Discussion
Subject: Re: Tobago sheet using jdbc ResultSet example request
Please remove the state attribute it should be a ref to a SheetState
Instance.
Please remove showRowRage, showDirectLinks and directLinkCount
attributes they make no sense for a dataModel for a resultSet because
the dataModel returns rowCount -1 for a resultSet.
Can you send me the ManagedBean code, please.
Bernd
John schrieb:
> That's what I thought - so I changed it to uppercase. Didn't affect
> the results.
>
> createTableStatement.execute("CREATE CACHED TABLE quarantine(FILENAME
> CHAR(64), SENDER CHAR(128), RECIPIENT CHAR(128), SUBJECT CHAR(128),
> FILTEREDBY CHAR(24), MATCHTEXT CHAR(128), CONSTRAINT cQuarPRI PRIMARY
> KEY (FILENAME))");
>
> <t:sheet
> value="#{quarantine.rslt}"
> id="sheet"
> columns="3*;1*;3*;3*;3*"
> var="quarantineRec"
> state="1"
> showRowRange="left"
> showPageRange="right"
> showDirectLinks="center"
> pagingLength="7"
> directLinkCount="5">
> <t:column label="From" id="name" sortable="true">
> <t:out value="#{quarantineRec.SENDER}" />
> </t:column>
> <t:column label="To" id="number" sortable="false"
> align="center">
> <t:out value="#{quarantineRec.RECIPIENT}" />
> </t:column>
> <t:column label="Subject" sortable="true">
> <t:out value="#{quarantineRec.SUBJECT}" />
> </t:column>
> <t:column label="Matched" sortable="true">
> <t:out value="#{quarantineRecr.MATCHTEXT}" />
> </t:column>
> <t:column label="Filtered" sortable="true" align="right">
> <t:out value="#{quarantineRec.FILTEREDBY}" />
> </t:column>
> </t:sheet>
>
> -----Original Message-----
> From: Bernd Bohmann [mailto:[EMAIL PROTECTED]
> Sent: Monday, March 06, 2006 11:02 AM
> To: MyFaces Discussion
> Subject: Re: Tobago sheet using jdbc ResultSet example request
>
> John,
>
> please send the sheet jsp and the definition of the table.
>
> Maybe a case-sensitive problem.
>
> Bernd
>
> John schrieb:
>
>>Ok.
>>
>>My bean is retrieving 2 rows, but they are not being displayed.
>>
>>In the definition of the tobago sheet, the var definition: It's
>>arbitrary, I'm assuming and doesn't map to any real variables in any
>>beans.
>>Ok. So assuming a var definition of: QuarantineRec Then in the t:outs
>
>
>>if I'm using: quarantineRec.SENDER where SENDER is a database column
>
>
>>in the returned ResultSet.........
>>
>>Does Tobago automatically know that SENDER is a db column?
>>
>>No data showing in the Tobago sheet.
>>
>>John
>>
>>-----Original Message-----
>>From: Bernd Bohmann [mailto:[EMAIL PROTECTED]
>>Sent: Monday, March 06, 2006 1:28 AM
>>To: MyFaces Discussion
>>Subject: Re: Tobago sheet using jdbc ResultSet example request
>>
>>
>>John schrieb:
>>
>>
>>>Thank you very much for the example.
>>>The trick seems to be having a function called 'select' within the
>>>backing bean, which tobago's sheet looks for to return data into the
>>>resultSet which has been provided within the sheet's value.
>>>
>>>Yes?
>>
>>
>>No, the select method is for the detail page.
>>
>>The getSolarObjects() method is for the sheet.
>>
>>The other get methods are for the detail page.
>>
>>
>>Bernd
>>
>>
>
>
> --
> Dipl.-Ing. Bernd Bohmann - Atanion GmbH - Software Development
> Bismarckstr. 13, 26122 Oldenburg, http://www.atanion.com
> phone: +49 441 4082312, mobile: +49 173 8839471, fax: +49 441 4082333
>
>
--
Dipl.-Ing. Bernd Bohmann - Atanion GmbH - Software Development
Bismarckstr. 13, 26122 Oldenburg, http://www.atanion.com
phone: +49 441 4082312, mobile: +49 173 8839471, fax: +49 441 4082333
