catch (ClassNotFoundException cnfe)
{
log("Unable to load driver", cnfe);
- return ;
+ return;
}
try
{
*
* It has no GUI, just a text frontend to keep it simple.
*
- * $Id: StockClient.java,v 1.4 2001/11/19 23:16:45 momjian Exp $
+ * $Id: StockClient.java,v 1.5 2001/11/19 23:19:20 momjian Exp $
*/
public class StockClient
{
if (nameServiceObj == null)
{
System.err.println("nameServiceObj == null");
- return ;
+ return;
}
nameService = org.omg.CosNaming.NamingContextHelper.narrow(nameServiceObj);
if (nameService == null)
{
System.err.println("nameService == null");
- return ;
+ return;
}
// Resolve the dispenser
if (dispenser == null)
{
System.err.println("dispenser == null");
- return ;
+ return;
}
// Now run the front end.
/*
* This class implements the server side of the example.
*
- * $Id: StockDispenserImpl.java,v 1.3 2001/11/19 22:43:13 momjian Exp $
+ * $Id: StockDispenserImpl.java,v 1.4 2001/11/19 23:19:20 momjian Exp $
*/
public class StockDispenserImpl extends stock._StockDispenserImplBase
{
{
stock[i].inUse = false;
System.out.println("Releasing slot " + i);
- return ;
+ return;
}
}
System.out.println("Reserved object not a member of this dispenser");
- return ;
+ return;
}
/*
/*
* This class implements the server side of the example.
*
- * $Id: StockServer.java,v 1.3 2001/11/19 22:43:13 momjian Exp $
+ * $Id: StockServer.java,v 1.4 2001/11/19 23:19:20 momjian Exp $
*/
public class StockServer
{
if (nameServiceObj == null)
{
System.err.println("nameServiceObj = null");
- return ;
+ return;
}
org.omg.CosNaming.NamingContext nameService = org.omg.CosNaming.NamingContextHelper.narrow(nameServiceObj);
if (nameService == null)
{
System.err.println("nameService = null");
- return ;
+ return;
}
// bind the dispenser into the naming service
if (line.startsWith("\\"))
{
processSlashCommand(line);
- return ;
+ return;
}
boolean type = st.execute(line);
import org.postgresql.core.*;
/*
- * $Id: Connection.java,v 1.37 2001/11/19 23:16:45 momjian Exp $
+ * $Id: Connection.java,v 1.38 2001/11/19 23:19:20 momjian Exp $
*
* This abstract class is used by org.postgresql.Driver to open either the JDBC1 or
* JDBC2 versions of the Connection class.
public void setAutoCommit(boolean autoCommit) throws SQLException
{
if (this.autoCommit == autoCommit)
- return ;
+ return;
if (autoCommit)
ExecSQL("end");
else
public void commit() throws SQLException
{
if (autoCommit)
- return ;
+ return;
if (haveMinimumServerVersion("7.1"))
{
ExecSQL("commit;begin;" + getIsolationLevelSQL());
public void rollback() throws SQLException
{
if (autoCommit)
- return ;
+ return;
if (haveMinimumServerVersion("7.1"))
{
ExecSQL("rollback; begin;" + getIsolationLevelSQL());
{
// If it's larger than maxsize then we don't touch it
if (b.length > maxsize)
- return ;
+ return;
ObjectPool not_usel = notusemap[b.length];
ObjectPool in_usel = inusemap[b.length];
{
if (b.length > maxsize)
{
- return ;
+ return;
}
ObjectPool not_usel = notusemap[b.length];
ObjectPool in_usel = inusemap[b.length];
int srcsize = pool.size();
if (srcsize == 0)
- return ;
+ return;
int totalsize = srcsize + cursize;
if (totalsize > maxsize)
{
if (x == null)
{
setNull(parameterIndex, Types.OTHER);
- return ;
+ return;
}
switch (targetSqlType)
{
if (x == null)
{
setNull(parameterIndex, Types.OTHER);
- return ;
+ return;
}
if (x instanceof String)
setString(parameterIndex, (String)x);
if (x == null)
{
setNull(parameterIndex, Types.OTHER);
- return ;
+ return;
}
switch (targetSqlType)
{
if (x == null)
{
setNull(parameterIndex, Types.OTHER);
- return ;
+ return;
}
if (x instanceof String)
setString(parameterIndex, (String)x);
{
DriverManager.println("Serialize.create: table " + tableName + " exists, skipping");
rs.close();
- return ;
+ return;
}
// else table not found, so create it
*
* Copyright 1999 (C) Exoffice Technologies Inc. All Rights Reserved.
*
-* $Id: ClientConnection.java,v 1.3 2001/11/19 22:33:39 momjian Exp $
+* $Id: ClientConnection.java,v 1.4 2001/11/19 23:19:21 momjian Exp $
*/
throws SQLException
{
if ( _xaConn == null )
- return ;
+ return;
// Notify the XA connection that we are no longer going
// to be used. Whether the underlying connection is released,
*
* Copyright 1999 (C) Exoffice Technologies Inc. All Rights Reserved.
*
-* $Id: XAConnectionImpl.java,v 1.3 2001/11/19 22:33:39 momjian Exp $
+* $Id: XAConnectionImpl.java,v 1.4 2001/11/19 23:19:21 momjian Exp $
*/
// We have to expect being called by a ClientConnection that we
// no longer regard as valid. That's acceptable, we just ignore.
if ( clientId != _clientId )
- return ;
+ return;
// If we are handling an underlying connection, we commit the
// old transaction and are ready to work for a new one.
event = new ConnectionEvent( this, except );
_listener.connectionErrorOccurred( event );
}
- return ;
+ return;
}
}
// Notify the listener.
ConnectionEvent event;
if ( clientId != _clientId )
- return ;
+ return;
// If the connection is not two-phase commit we cannot determine
// whether the error is critical, we just return. If the connection
{
if ( ! ( _underlying instanceof TwoPhaseConnection ) ||
! ( (TwoPhaseConnection) _underlying ).isCriticalError( except ) )
- return ;
+ return;
if ( _txConn.conn == null ||
! ( _txConn.conn instanceof TwoPhaseConnection ) ||
! ( (TwoPhaseConnection) _txConn.conn ).isCriticalError( except ) )
- return ;
+ return;
}
// The client connection is no longer useable, the underlying
// If connection has been prepared and is read-only,
// nothing to do at this stage.
if ( txConn.readOnly )
- return ;
+ return;
// This must be a one-phase commite, or the connection
// should have been prepared before.
// been terminated any other way, nothing to do
// either.
if ( txConn.readOnly || txConn.conn == null )
- return ;
+ return;
try
{
projects / postgresql / commitdiff