mcs/class/Npgsql/Npgsql/NpgsqlBind.cs

   1 // created on 29/6/2003 at 13:28
   2
   3 // Npgsql.NpgsqlBind.cs
   4 //
   5 // Author:
   6 //      Francisco Jr. (fxjrlists@yahoo.com.br)
   7 //
   8 //      Copyright (C) 2002 The Npgsql Development Team
   9 //      npgsql-general@gborg.postgresql.org
  10 //      http://gborg.postgresql.org/project/npgsql/projdisplay.php
  11 //
  12 // This library is free software; you can redistribute it and/or
  13 // modify it under the terms of the GNU Lesser General Public
  14 // License as published by the Free Software Foundation; either
  15 // version 2.1 of the License, or (at your option) any later version.
  16 //
  17 // This library is distributed in the hope that it will be useful,
  18 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  19 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  20 // Lesser General Public License for more details.
  21 //
  22 // You should have received a copy of the GNU Lesser General Public
  23 // License along with this library; if not, write to the Free Software
  24 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  25
  26 using System;
  27 using System.IO;
  28 using System.Text;
  29
  30 namespace Npgsql
  31 {
  32
  33     /// <summary>
  34     /// This class represents the Bind message sent to PostgreSQL
  35     /// server.
  36     /// </summary>
  37     ///
  38     internal sealed class NpgsqlBind
  39     {
  40
  41         // Logging related values
  42         private static readonly String CLASSNAME = "NpgsqlBind";
  43
  44         private String _portalName;
  45         private String _preparedStatementName;
  46         private Int16[] _parameterFormatCodes;
  47         private Object[] _parameterValues;
  48         private Int16[] _resultFormatCodes;
  49
  50
  51         public NpgsqlBind(String portalName,
  52                           String preparedStatementName,
  53                           Int16[] parameterFormatCodes,
  54                           Object[] parameterValues,
  55                           Int16[] resultFormatCodes)
  56         {
  57
  58             _portalName = portalName;
  59             _preparedStatementName = preparedStatementName;
  60             _parameterFormatCodes = parameterFormatCodes;
  61             _parameterValues = parameterValues;
  62             _resultFormatCodes = resultFormatCodes;
  63
  64
  65         }
  66
  67         public String PortalName
  68         {
  69             get
  70             {
  71                 return _portalName;
  72             }
  73         }
  74
  75         public Int16[] ParameterFormatCodes
  76         {
  77             get
  78             {
  79                 return _parameterFormatCodes;
  80             }
  81
  82             set
  83             {
  84                 _parameterFormatCodes = value;
  85             }
  86         }
  87
  88         public Object[] ParameterValues
  89         {
  90             get
  91             {
  92                 return _parameterValues;
  93             }
  94
  95             set
  96             {
  97                 _parameterValues = value;
  98             }
  99         }
 100
 101
 102         public void WriteToStream(Stream outputStream, Encoding encoding)
 103         {
 104
 105
 106
 107             Int32 messageLength = 4 +
 108                                   encoding.GetByteCount(_portalName) + 1 +
 109                                   encoding.GetByteCount(_preparedStatementName) + 1 +
 110                                   2 +
 111                                   (_parameterFormatCodes.Length * 2) +
 112                                   2;
 113
 114
 115             // Get size of parameter values.
 116             Int32 i;
 117
 118             if (_parameterValues != null)
 119                 for (i = 0; i < _parameterValues.Length; i++)
 120                 {
 121                     messageLength += 4;
 122                     if ( _parameterValues[i] != null)
 123                         if ( ((_parameterFormatCodes.Length == 1) && (_parameterFormatCodes[0] == (Int16) FormatCode.Binary)) ||
 124                                 ((_parameterFormatCodes.Length != 1) && (_parameterFormatCodes[i] == (Int16) FormatCode.Binary)) )
 125                             messageLength += ((Byte[])_parameterValues[i]).Length;
 126                         else
 127                             messageLength += encoding.GetByteCount((String)_parameterValues[i]);
 128
 129                 }
 130
 131             messageLength += 2 + (_resultFormatCodes.Length * 2);
 132
 133
 134             outputStream.WriteByte((Byte)'B');
 135
 136             PGUtil.WriteInt32(outputStream, messageLength);
 137             PGUtil.WriteString(_portalName, outputStream, encoding);
 138             PGUtil.WriteString(_preparedStatementName, outputStream, encoding);
 139
 140             PGUtil.WriteInt16(outputStream, (Int16)_parameterFormatCodes.Length);
 141
 142             for (i = 0; i < _parameterFormatCodes.Length; i++)
 143                 PGUtil.WriteInt16(outputStream, _parameterFormatCodes[i]);
 144
 145             if (_parameterValues != null)
 146             {
 147                 PGUtil.WriteInt16(outputStream, (Int16)_parameterValues.Length);
 148
 149                 for (i = 0; i < _parameterValues.Length; i++)
 150                 {
 151                     if ( ((_parameterFormatCodes.Length == 1) && (_parameterFormatCodes[0] == (Int16) FormatCode.Binary)) ||
 152                             ((_parameterFormatCodes.Length != 1) && (_parameterFormatCodes[i] == (Int16) FormatCode.Binary)) )
 153                     {
 154
 155                         Byte[] parameterValue = (Byte[])_parameterValues[i];
 156                         if (parameterValue == null)
 157                             PGUtil.WriteInt32(outputStream, -1);
 158                         else
 159                         {
 160                             PGUtil.WriteInt32(outputStream, parameterValue.Length);
 161                             outputStream.Write(parameterValue, 0, parameterValue.Length);
 162                         }
 163                     }
 164                     else
 165                     {
 166                         String parameterValue = (String)_parameterValues[i];
 167                         if (parameterValue == null)
 168                             PGUtil.WriteInt32(outputStream, -1);
 169                         else
 170                         {
 171                             PGUtil.WriteInt32(outputStream, encoding.GetByteCount(parameterValue));
 172                             outputStream.Write(encoding.GetBytes(parameterValue), 0, encoding.GetByteCount(parameterValue));
 173                         }
 174                     }
 175
 176                 }
 177             }
 178             else
 179                 PGUtil.WriteInt16(outputStream, 0);
 180
 181             PGUtil.WriteInt16(outputStream, (Int16)_resultFormatCodes.Length);
 182             for (i = 0; i < _resultFormatCodes.Length; i++)
 183                 PGUtil.WriteInt16(outputStream, _resultFormatCodes[i]);
 184
 185
 186
 187         }
 188
 189     }
 190 }
 191