string database = String.Empty;
string connectDB;
string charset;
- string hostname = "tux";
+ string hostname;
string server;
string language;
string libraryName;
int packetSize;
string password;
+ int port;
string progName;
string user;
//TdsCommand command;
IsolationLevel isolationLevel;
bool autoCommit;
- Socket socket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
+ Socket socket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
#endregion // Fields
connectDB = parms.Database;
encoder = Encoding.GetEncoding (parms.Encoding);
charset = parms.Encoding;
- server = parms.Host;
+ hostname = parms.Hostname;
+ server = parms.DataSource;
language = parms.Language;
libraryName = parms.LibraryName;
packetSize = parms.PacketSize;
password = parms.Password;
+ port = parms.Port;
progName = parms.ProgName;
tdsVersion = parms.TdsVersion;
user = parms.User;
- IPHostEntry hostEntry = Dns.GetHostByName (parms.Host);
+ IPHostEntry hostEntry = Dns.Resolve (server);
IPAddress[] addresses = hostEntry.AddressList;
IPEndPoint endPoint;
foreach (IPAddress address in addresses) {
- endPoint = new IPEndPoint (address, parms.Port);
+ endPoint = new IPEndPoint (address, port);
socket.Connect (endPoint);
if (socket.Connected)
#endregion // Constructors
#region Methods
-
+
+ public void BeginTransaction ()
+ {
+ SubmitProcedure ("BEGIN TRANSACTION");
+ }
public void ChangeDatabase (string databaseName)
{
+ TdsPacketResult result;
+ bool isOkay;
+
string query = String.Format ("use {0}", databaseName);
comm.StartPacket (TdsPacketType.Query);
comm.Append (query);
comm.SendPacket ();
+
+ while (!((result = ProcessSubPacket ()) is TdsPacketEndTokenResult)) {
+ if (result is TdsPacketErrorResult) {
+ isOkay = false;
+ }
+ }
}
public void ChangeSettings (bool autoCommit, IsolationLevel isolationLevel)
return isOkay;
}
+ public void CommitTransaction ()
+ {
+ string sql = "IF @@TRANCOUNT>0 COMMIT TRAN";
+ SubmitProcedure (sql);
+ }
+
+ [MonoTODO ("fixme")]
+ public int ExecuteNonQuery (string sql)
+ {
+ TdsPacketResult result;
+ bool done = false;
+
+ if (sql.Length > 0) {
+ comm.StartPacket (TdsPacketType.Query);
+ comm.Append (sql);
+ moreResults2 = true;
+ comm.SendPacket ();
+ }
+
+ do {
+ result = ProcessSubPacket ();
+ if (result is TdsPacketMessageResult) {
+ Console.WriteLine (((TdsPacketMessageResult) result).Message);
+ }
+ done = (result is TdsPacketEndTokenResult) && (!((TdsPacketEndTokenResult) result).MoreResults);
+
+ } while (!done);
+
+ return -1;
+ }
+
+ [MonoTODO ("fixme")]
+ public void ExecuteQuery (string sql)
+ {
+ if (sql.Length > 0) {
+ comm.StartPacket (TdsPacketType.Query);
+ comm.Append (sql);
+ moreResults2 = true;
+ comm.SendPacket ();
+ }
+ }
+
private object GetCharValue (bool wideChars, bool outputParam)
{
object result = null;
else
result = encoder.GetString (comm.GetBytes (len, false), 0, len);
- if ((byte) tdsVersion < (byte) TdsVersion.tds70 && result == " ")
+ if (tdsVersion < TdsVersion.tds70 && ((string) result).Equals (" "))
result = "";
}
else
return result;
}
- [System.MonoTODO]
+ [MonoTODO]
private object GetDecimalValue (int scale)
{
throw new NotImplementedException ();
}
- [System.MonoTODO]
+ [MonoTODO]
private object GetDateTimeValue (TdsColumnType type)
{
throw new NotImplementedException ();
return result;
}
- [System.MonoTODO]
+ [MonoTODO]
private object GetMoneyValue (TdsColumnType type)
{
int len;
}
}
- [System.MonoTODO]
+ [MonoTODO]
private TdsPacketRowResult LoadRow (TdsPacketRowResult result)
{
throw new NotImplementedException ();
return new TdsPacketColumnInfoResult (table.Columns);
}
- [System.MonoTODO]
+ [MonoTODO]
private TdsPacketEndTokenResult ProcessEndToken (TdsPacketSubType type)
{
byte status = comm.GetByte ();
TdsPacketEndTokenResult result = new TdsPacketEndTokenResult (type, status, rowCount);
+ Console.WriteLine ("Row count {0}", rowCount);
+
moreResults = result.MoreResults;
// FIXME: Finish the query
comm.GetString (comm.GetByte () & 0xff);
comm.Skip (5);
TdsColumnType colType = (TdsColumnType) comm.GetByte ();
+ int len;
object element = null;
switch (colType) {
break;
case TdsColumnType.BigVarBinary :
comm.GetTdsShort ();
- int len = comm.GetTdsShort ();
+ len = comm.GetTdsShort ();
element = comm.GetBytes (len, true);
break;
case TdsColumnType.BigVarChar :
case TdsColumnType.VarBinary :
case TdsColumnType.Binary :
comm.GetByte ();
- int len = (comm.GetByte () & 0xff);
+ len = (comm.GetByte () & 0xff);
element = comm.GetBytes (len, true);
break;
case TdsColumnType.BitN :
element = (columnSize != 0);
break;
case TdsColumnType.UniqueIdentifier :
- int len = comm.GetByte () & 0xff;
- element = (len == 0 ? null : new Guid (comm.GetBytes (len, false)));
+ len = comm.GetByte () & 0xff;
+ //element = (len == 0 ? null : new Guid (comm.GetBytes (len, false)));
break;
default :
throw new TdsException ("");
return new TdsPacketRetStatResult (comm.GetTdsInt ());
}
- [System.MonoTODO]
+ [MonoTODO]
private TdsPacketResult ProcessSubPacket ()
{
TdsPacketResult result = null;
switch (subType) {
case TdsPacketSubType.EnvChange :
+Console.WriteLine ("Environment change");
result = ProcessEnvChange ();
break;
case TdsPacketSubType.Error :
case TdsPacketSubType.Info :
case TdsPacketSubType.Msg50Token :
+Console.WriteLine ("Error/info/message");
result = ProcessMessage (subType);
break;
case TdsPacketSubType.Param :
+Console.WriteLine ("Param");
result = ProcessOutputParam ();
break;
case TdsPacketSubType.LoginAck :
+Console.WriteLine ("Login Ack");
result = ProcessLoginAck ();
break;
case TdsPacketSubType.ReturnStatus :
+Console.WriteLine ("Return Status");
result = ProcessReturnStatus ();
break;
case TdsPacketSubType.ProcId :
+Console.WriteLine ("Proc Id");
result = ProcessProcId ();
break;
case TdsPacketSubType.Done :
case TdsPacketSubType.DoneProc :
case TdsPacketSubType.DoneInProc :
+Console.WriteLine ("Done");
result = ProcessEndToken (subType);
moreResults2 = ((TdsPacketEndTokenResult) result).MoreResults;
break;
case TdsPacketSubType.ColumnNameToken :
+Console.WriteLine ("Column Name");
result = ProcessColumnNames ();
break;
case TdsPacketSubType.ColumnInfoToken :
+Console.WriteLine ("Column Info");
result = ProcessColumnInfo ();
break;
case TdsPacketSubType.Unknown0xA5 :
case TdsPacketSubType.Unknown0xA7 :
case TdsPacketSubType.Unknown0xA8 :
+Console.WriteLine ("Unknown");
comm.Skip (comm.GetTdsShort ());
result = new TdsPacketUnknown (subType);
break;
case TdsPacketSubType.TableName :
+Console.WriteLine ("Table Name");
result = ProcessTableName ();
break;
case TdsPacketSubType.Order :
+Console.WriteLine ("Order");
comm.Skip (comm.GetTdsShort ());
result = new TdsPacketColumnOrderResult ();
break;
case TdsPacketSubType.Control :
+Console.WriteLine ("Control");
comm.Skip (comm.GetTdsShort ());
result = new TdsPacketControlResult ();
break;
case TdsPacketSubType.Row :
+Console.WriteLine ("Row");
result = LoadRow (new TdsPacketRowResult (null));
break;
case TdsPacketSubType.ColumnMetadata :
+Console.WriteLine ("Column Metadata");
result = ProcessTds7Result ();
break;
default:
return new TdsPacketTableNameResult ();
}
- [System.MonoTODO ("complete")]
+ [MonoTODO ("complete")]
private TdsPacketResult ProcessTds7Result ()
{
int numColumns = comm.GetTdsShort ();
return tmp;
}
+ [MonoTODO]
+ public void RollbackTransaction ()
+ {
+ SubmitProcedure ("IF @@TRANCOUNT>0 ROLLBACK TRAN");
+ }
+
+ [MonoTODO]
+ public void SaveTransaction (string savePointName)
+ {
+ string sql = String.Format ("SAVE TRAN {0}", savePointName);
+ SubmitProcedure (sql);
+ }
+
private void SetCharset (string charset)
{
if (charset == null || charset.Length > 30)
}
}
+ public void SubmitProcedure (string sql)
+ {
+ TdsPacketResult result;
+ ExecuteQuery (sql);
+ bool done;
+ do {
+ result = ProcessSubPacket ();
+ if (result is TdsPacketMessageResult) {
+ Console.WriteLine (((TdsPacketMessageResult) result).Message);
+ }
+ done = (result is TdsPacketEndTokenResult) && (!((TdsPacketEndTokenResult) result).MoreResults);
+
+ } while (!done);
+ }
+
public bool Logon (TdsConnectionParameters parms)
{
byte pad = (byte) 0;
return result;
}
- [System.MonoTODO]
+ [MonoTODO]
private string SqlStatementToSetIsolationLevel ()
{
string result = "";
projects / mono.git / blobdiff