From 00923229c2f076d241daf03dbc05e1458539c6d3 Mon Sep 17 00:00:00 2001 From: Dave Cramer Date: Thu, 21 Mar 2002 02:40:03 +0000 Subject: [PATCH] Part of Anders Bengtsson's patch to clean up Connection.java --- .../org/postgresql/core/StartupPacket.java | 43 +++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 src/interfaces/jdbc/org/postgresql/core/StartupPacket.java diff --git a/src/interfaces/jdbc/org/postgresql/core/StartupPacket.java b/src/interfaces/jdbc/org/postgresql/core/StartupPacket.java new file mode 100644 index 0000000000..223f16ebd4 --- /dev/null +++ b/src/interfaces/jdbc/org/postgresql/core/StartupPacket.java @@ -0,0 +1,43 @@ +package org.postgresql.core; + +import org.postgresql.PG_Stream; +import java.io.IOException; + +/** + * Sent to the backend to initialize a newly created connection. + * + * $Id: StartupPacket.java,v 1.1 2002/03/21 02:40:03 davec Exp $ + */ + +public class StartupPacket +{ + private static final int SM_DATABASE = 64; + private static final int SM_USER = 32; + private static final int SM_OPTIONS = 64; + private static final int SM_UNUSED = 64; + private static final int SM_TTY = 64; + + private int protocolMajor; + private int protocolMinor; + private String user; + private String database; + + public StartupPacket(int protocolMajor, int protocolMinor, String user, String database) { + this.protocolMajor = protocolMajor; + this.protocolMinor = protocolMinor; + this.user = user; + this.database = database; + } + + public void writeTo(PG_Stream stream) throws IOException + { + stream.SendInteger(4 + 4 + SM_DATABASE + SM_USER + SM_OPTIONS + SM_UNUSED + SM_TTY, 4); + stream.SendInteger(protocolMajor, 2); + stream.SendInteger(protocolMinor, 2); + stream.Send(database.getBytes(), SM_DATABASE); + + // This last send includes the unused fields + stream.Send(user.getBytes(), SM_USER + SM_OPTIONS + SM_UNUSED + SM_TTY); + } +} + -- 2.40.0