class/Npgsql/NpgsqlTypes/FastPathArg.cs

   1 /*-------------------------------------------------------------------------
   2
   3   FastpathArg.cs
   4       This class is a port of the class FastpathArg.java implemented by
   5       PostgreSQL Global Development Group
   6
   7  Copyright (c) 2004, Emiliano Necciari
   8  Original Code: Copyright (c) 2003, PostgreSQL Global Development Group
   9
  10  Note: (Francisco Figueiredo Jr.)
  11         Changed case of method names to conform to .Net names standard.
  12         Also changed type names to their true names. i.e. int -> Int32
  13
  14  This library is free software; you can redistribute it and/or
  15  modify it under the terms of the GNU Lesser General Public
  16  License as published by the Free Software Foundation; either
  17  version 2.1 of the License, or (at your option) any later version.
  18
  19  This library is distributed in the hope that it will be useful,
  20  but WITHOUT ANY WARRANTY; without even the implied warranty of
  21  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  22  Lesser General Public License for more details.
  23
  24  You should have received a copy of the GNU Lesser General Public
  25  License along with this library; if not, write to the Free Software
  26  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  27 -------------------------------------------------------------------------
  28 */
  29
  30 using System;
  31 using System.IO;
  32 using Npgsql;
  33
  34 namespace NpgsqlTypes
  35 {
  36     public class FastpathArg
  37     {
  38         /*
  39          * Type of argument, true=integer, false=byte[]
  40          */
  41         public Boolean type;
  42
  43         /*
  44          * Integer value if type=true
  45          */
  46         public Int32 value;
  47
  48         /*
  49          * Byte value if type=false;
  50          */
  51         public Byte[] bytes;
  52
  53         /*
  54          * Constructs an argument that consists of an integer value
  55          * @param value int value to set
  56          */
  57         public FastpathArg(Int32 value)
  58         {
  59             type = true;
  60             this.value = value;
  61         }
  62
  63         /*
  64          * Constructs an argument that consists of an array of bytes
  65          * @param bytes array to store
  66          */
  67         public FastpathArg(Byte[] bytes)
  68         {
  69             type = false;
  70             this.bytes = bytes;
  71         }
  72
  73         /*
  74          * Constructs an argument that consists of part of a byte array
  75          * @param buf source array
  76          * @param off offset within array
  77          * @param len length of data to include
  78          */
  79         public FastpathArg(Byte[] buf, Int32 off, Int32 len)
  80         {
  81             type = false;
  82             bytes = new Byte[len];
  83             //TODO:
  84             bytes = buf;
  85         }
  86
  87         /*
  88          * Constructs an argument that consists of a String.
  89          * @param s String to store
  90          */
  91         public FastpathArg(String s)
  92         {
  93             //this(s.ToCharArray());
  94         }
  95
  96         /*
  97          * This sends this argument down the network stream.
  98          *
  99          * <p>The stream sent consists of the length.int4 then the contents.
 100          *
 101          * <p><b>Note:</b> This is called from Fastpath, and cannot be called from
 102          * client code.
 103          *
 104          * @param s output stream
 105          * @exception IOException if something failed on the network stream
 106          */
 107         public void Send(Stream s)
 108         {
 109             if (type)
 110             {
 111                 // argument is an integer
 112                 PGUtil.WriteInt32(s, 4);
 113                 PGUtil.WriteInt32(s, value);    // integer value of argument
 114             }
 115             else
 116             {
 117                 // argument is a byte array
 118                 PGUtil.WriteInt32(s, bytes.Length);
 119                 s.Write(bytes,0,bytes.Length);
 120             }
 121         }
 122
 123         public Int32 SendSize()
 124         {
 125             if (type)
 126             {
 127                 return 8;
 128             }
 129             else
 130             {
 131                 return 4+bytes.Length;
 132             }
 133         }
 134     }
 135 }