The SQL Anywhere JDBC driver supports two asynchronous callbacks, one for handling the SQL MESSAGE statement and the other for validating requests for file transfers.
Messages can be sent to the client application from the database server using the SQL MESSAGE statement. Messages can also be generated by long running database server statements.
A message handler routine can be created to intercept these messages. The following is an example of a message handler callback routine.
class T_message_handler implements sybase.jdbc4.sqlanywhere.ASAMessageHandler
{
private final int MSG_INFO = 0x80 | 0;
private final int MSG_WARNING = 0x80 | 1;
private final int MSG_ACTION = 0x80 | 2;
private final int MSG_STATUS = 0x80 | 3;
T_message_handler()
{
}
public SQLException messageHandler(SQLException sqe)
{
String msg_type = "unknown";
switch( sqe.getErrorCode() ) {
case MSG_INFO: msg_type = "INFO "; break;
case MSG_WARNING: msg_type = "WARNING"; break;
case MSG_ACTION: msg_type = "ACTION "; break;
case MSG_STATUS: msg_type = "STATUS "; break;
}
System.out.println( msg_type + ": " + sqe.getMessage() );
return sqe;
}
}
A client file transfer request can be validated. Before allowing any transfer to take place, the JDBC driver will invoke the validation callback, if it exists. If the client data transfer is being requested during the execution of indirect statements such as from within a stored procedure, the JDBC driver will not allow a transfer unless the client application has registered a validation callback. The conditions under which a validation call is made are described more fully below. The following is an example of a file transfer validation callback routine.
class T_filetrans_callback implements sybase.jdbc4.sqlanywhere.SAValidateFileTransferCallback
{
T_filetrans_callback()
{
}
public int callback(String filename, int is_write)
{
System.out.println( "File transfer granted for file " + filename +
" with an is_write value of " + is_write );
return( 1 ); // 0 to disallow, non-zero to allow
}
}
The filename argument is the name of the file to be read or written. The is_write parameter is 0 if a read is requested (transfer from the client to the server), and non-zero for a write. The callback function should return 0 if the file transfer is not allowed, non-zero otherwise.
For data security, the server tracks the origin of statements requesting a file transfer. The server determines if the statement was received directly from the client application. When initiating the transfer of data from the client, the server sends the information about the origin of the statement to the client software. On its part, the JDBC driver allows unconditional transfer of data only if the data transfer is being requested due to the execution of a statement sent directly by the client application. Otherwise, the application must have registered the validation callback described above, in the absence of which the transfer is denied and the statement fails with an error. If the client statement invokes a stored procedure already existing in the database, then the execution of the stored procedure itself is considered not to have been for a client initiated statement. However, if the client application explicitly creates a temporary stored procedure then the execution of the stored procedure results in the server treating the procedure as having been client initiated. Similarly, if the client application executes a batch statement, then the execution of the batch statement is considered as being done directly by the client application.
The following sample Java application demonstrates the use of the callbacks supported by the SQL Anywhere JDBC 4.0 driver. You need to place the file %ALLUSERSPROFILE%\SybaseIQ\samples\java\sajdbc4.jar in your classpath.
import java.io.*;
import java.sql.*;
import java.util.*;
public class callback
{
public static void main (String args[]) throws IOException
{
Connection con = null;
Statement stmt;
System.out.println ( "Starting... " );
con = connect();
if( con == null )
{
return; // exception should already have been reported
}
System.out.println ( "Connected... " );
try
{
// create and register message handler callback
T_message_handler message_worker = new T_message_handler();
((sybase.jdbc4.sqlanywhere.IConnection)con).setASAMessageHandler( message_worker );
// create and register validate file transfer callback
T_filetrans_callback filetran_worker = new T_filetrans_callback();
((sybase.jdbc4.sqlanywhere.IConnection)con).setSAValidateFileTransferCallback( filetran_worker );
stmt = con.createStatement();
// execute message statements to force message handler to be called
stmt.execute( "MESSAGE 'this is an info message' TYPE INFO TO CLIENT" );
stmt.execute( "MESSAGE 'this is an action message' TYPE ACTION TO CLIENT" );
stmt.execute( "MESSAGE 'this is a warning message' TYPE WARNING TO CLIENT" );
stmt.execute( "MESSAGE 'this is a status message' TYPE STATUS TO CLIENT" );
System.out.println( "\n==================\n" );
stmt.execute( "set temporary option allow_read_client_file='on'" );
try
{
stmt.execute( "drop procedure read_client_file_test" );
}
catch( SQLException dummy )
{
// ignore exception if procedure does not exist
}
// create procedure that will force file transfer callback to be called
stmt.execute( "create procedure read_client_file_test()" +
"begin" +
" declare v long binary;" +
" set v = read_client_file('sample.txt');" +
"end" );
// call procedure to force validate file transfer callback to be called
try
{
stmt.execute( "call read_client_file_test()" );
}
catch( SQLException filetrans_exception )
{
// Note: Since the file transfer callback returns 1,
// do not expect a SQL exception to be thrown
System.out.println( "SQLException: " +
filetrans_exception.getMessage() );
}
stmt.close();
con.close();
System.out.println( "Disconnected" );
}
catch( SQLException sqe )
{
printExceptions(sqe);
}
}
private static Connection connect()
{
Connection connection;
System.out.println( "Using jdbc4 driver" );
try
{
connection = DriverManager.getConnection(
"jdbc:sqlanywhere:uid=DBA;pwd=sql" );
}
catch( Exception e )
{
System.err.println( "Error! Could not connect" );
System.err.println( e.getMessage() );
printExceptions( (SQLException)e );
connection = null;
}
return connection;
}
static private void printExceptions(SQLException sqe)
{
while (sqe != null)
{
System.out.println("Unexpected exception : " +
"SqlState: " + sqe.getSQLState() +
" " + sqe.toString() +
", ErrorCode: " + sqe.getErrorCode());
System.out.println( "==================\n" );
sqe = sqe.getNextException();
}
}
}