mcs/class/ByteFX.Data/mysqlclient/CommandResult.cs

   1 using System;
   2
   3 namespace ByteFX.Data.MySqlClient
   4 {
   5         /// <summary>
   6         /// Summary description for CommandResult.
   7         /// </summary>
   8         internal class CommandResult
   9         {
  10                 private Driver  driver;
  11                 private Packet  packet;
  12                 private int             affectedRows = -1;
  13                 private int             fieldCount = -1;
  14                 private int             fieldsRead = 0;
  15                 private long    fieldLength = 0;
  16                 private bool    readSchema = false;
  17                 private bool    readRows = false;
  18
  19                 public CommandResult(Packet p, Driver d)
  20                 {
  21                         driver = d;
  22                         packet = p;
  23                         fieldCount = (int)p.ReadLenInteger();
  24                         if (fieldCount == 0)
  25                                 affectedRows =(int)p.ReadLenInteger();
  26                 }
  27
  28                 #region Properties
  29                 public bool IsResultSet
  30                 {
  31                         get { return fieldCount > 0; }
  32                 }
  33
  34                 public int ColumnCount
  35                 {
  36                         get { return fieldCount; }
  37                 }
  38
  39                 public int RowsAffected
  40                 {
  41                         get { return affectedRows; }
  42                 }
  43
  44                 #endregion
  45
  46                 public MySqlField GetField()
  47                 {
  48                         MySqlField f = new MySqlField( driver.Encoding );
  49                         packet = driver.ReadPacket();
  50
  51                         f.TableName = packet.ReadLenString();
  52                         f.ColumnName = packet.ReadLenString();
  53                         f.ColumnLength = (int)packet.ReadNBytes();
  54                         f.Type = (MySqlDbType)packet.ReadNBytes();
  55                         packet.ReadByte();                                                                      // this is apparently 2 -- not sure what it is for
  56                         f.Flags = (ColumnFlags)packet.ReadInteger(2);           //(short)(d.ReadByte() & 0xff);
  57                         f.NumericScale = packet.ReadByte();
  58                         fieldsRead++;
  59                         return f;
  60                 }
  61
  62                 public byte[] GetFieldBuffer()
  63                 {
  64                         return packet.GetBuffer();
  65                 }
  66
  67                 public int GetFieldIndex()
  68                 {
  69                         return (int)packet.Position;
  70                 }
  71
  72                 public long GetFieldLength()
  73                 {
  74                         return fieldLength;
  75                 }
  76
  77                 public bool NextField()
  78                 {
  79                         if (fieldLength >= 0)
  80                                 packet.Position += fieldLength;
  81                         if (! packet.HasMoreData) return false;
  82                         fieldLength = packet.ReadLenInteger();
  83                         fieldsRead++;
  84                         return true;
  85                 }
  86
  87
  88                 /// <summary>
  89                 /// Checks to see if there are any row packets coming
  90                 /// </summary>
  91                 /// <returns>True if there are row packets available, false if not</returns>
  92                 public bool CheckForRows()
  93                 {
  94                         // first read off any unread field defs
  95                         while (fieldsRead < fieldCount)
  96                                 GetField();
  97
  98                         // read off the end of schema packet
  99                         packet = driver.ReadPacket();
 100                         if ( ! packet.IsLastPacket())
 101                                 throw new MySqlException("Expected end of schema packet");
 102                         readSchema = true;
 103
 104                         packet = driver.PeekPacket();
 105                         return ! packet.IsLastPacket();
 106                 }
 107
 108                 public bool ReadDataRow()
 109                 {
 110                         packet = driver.ReadPacket();
 111                         if (packet.IsLastPacket())
 112                         {
 113                                 readRows = true;
 114                                 return false;
 115                         }
 116                         fieldsRead = 0;
 117                         fieldLength = 0;
 118                         NextField();
 119                         return true;
 120                 }
 121
 122                 public void Clear()
 123                 {
 124                         Packet p;
 125
 126                         if (! readSchema)
 127                         {
 128                                 do
 129                                 {
 130                                         p = driver.ReadPacket();
 131                                 } while (! p.IsLastPacket());
 132                         }
 133
 134                         if (! readRows)
 135                                 do
 136                                 {
 137                                         p = driver.ReadPacket();
 138                                 } while (! p.IsLastPacket());
 139                 }
 140         }
 141 }