mcs/class/Npgsql/Npgsql/NpgsqlReadyState.cs

   1 // Npgsql.NpgsqlReadyState.cs
   2 //
   3 // Author:
   4 //      Dave Joyner <d4ljoyn@yahoo.com>
   5 //
   6 //      Copyright (C) 2002 The Npgsql Development Team
   7 //      npgsql-general@gborg.postgresql.org
   8 //      http://gborg.postgresql.org/project/npgsql/projdisplay.php
   9 //
  10 // This library is free software; you can redistribute it and/or
  11 // modify it under the terms of the GNU Lesser General Public
  12 // License as published by the Free Software Foundation; either
  13 // version 2.1 of the License, or (at your option) any later version.
  14 //
  15 // This library is distributed in the hope that it will be useful,
  16 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  18 // Lesser General Public License for more details.
  19 //
  20 // You should have received a copy of the GNU Lesser General Public
  21 // License along with this library; if not, write to the Free Software
  22 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  23
  24
  25 using System;
  26 using System.IO;
  27 using System.Net;
  28 using System.Net.Sockets;
  29 using System.Resources;
  30
  31 namespace Npgsql
  32 {
  33
  34
  35     internal sealed class NpgsqlReadyState : NpgsqlState
  36     {
  37         private static NpgsqlReadyState _instance = null;
  38
  39
  40         // Flush and Sync messages. It doesn't need to be created every time it is called.
  41         private static readonly NpgsqlFlush _flushMessage = new NpgsqlFlush();
  42
  43         private static readonly NpgsqlSync _syncMessage = new NpgsqlSync();
  44
  45         private readonly String CLASSNAME = "NpgsqlReadyState";
  46
  47         private NpgsqlReadyState() : base()
  48         { }
  49
  50         public static NpgsqlReadyState Instance
  51         {
  52             get
  53             {
  54                 if ( _instance == null )
  55                 {
  56                     _instance = new NpgsqlReadyState();
  57                 }
  58                 return _instance;
  59             }
  60         }
  61
  62
  63
  64         public override void Query( NpgsqlConnection context, NpgsqlCommand command )
  65         {
  66
  67             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Query");
  68
  69             String commandText = command.GetCommandText();
  70             NpgsqlEventLog.LogMsg(resman, "Log_QuerySent", LogLevel.Debug, commandText);
  71
  72             // Send the query request to backend.
  73
  74             NpgsqlQuery query = new NpgsqlQuery(commandText, context.BackendProtocolVersion);
  75             BufferedStream stream = new BufferedStream(context.Stream);
  76             query.WriteToStream(stream, context.Encoding);
  77             stream.Flush();
  78
  79             ProcessBackendResponses(context);
  80
  81         }
  82
  83         public override void Parse(NpgsqlConnection context, NpgsqlParse parse)
  84         {
  85             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Parse");
  86             BufferedStream stream = new BufferedStream(context.Stream);
  87             parse.WriteToStream(stream, context.Encoding);
  88             stream.Flush();
  89
  90
  91         }
  92
  93
  94         public override void Sync(NpgsqlConnection context)
  95         {
  96             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Sync");
  97             _syncMessage.WriteToStream(context.Stream, context.Encoding);
  98             ProcessBackendResponses(context);
  99         }
 100
 101         public override void Flush(NpgsqlConnection context)
 102         {
 103             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Flush");
 104             _flushMessage.WriteToStream(context.Stream, context.Encoding);
 105             ProcessBackendResponses(context);
 106         }
 107
 108         public override void Bind(NpgsqlConnection context, NpgsqlBind bind)
 109         {
 110             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Bind");
 111             BufferedStream stream = new BufferedStream(context.Stream);
 112             bind.WriteToStream(stream, context.Encoding);
 113             stream.Flush();
 114
 115         }
 116
 117         public override void Execute(NpgsqlConnection context, NpgsqlExecute execute)
 118         {
 119
 120             NpgsqlEventLog.LogMethodEnter(LogLevel.Debug, CLASSNAME, "Execute");
 121             NpgsqlDescribe describe = new NpgsqlDescribe('P', execute.PortalName);
 122             BufferedStream stream = new BufferedStream(context.Stream);
 123             describe.WriteToStream(stream, context.Encoding);
 124             execute.WriteToStream(stream, context.Encoding);
 125             stream.Flush();
 126             Sync(context);
 127         }
 128
 129     }
 130 }