#region Fields
string connectionString;
- int connectionTimeout = 15;
- OleDbDataReader dataReader;
- bool dataReaderOpen;
-
- IntPtr gdaConnection = IntPtr.Zero;
+ int connectionTimeout;
+ IntPtr gdaConnection;
#endregion
public OleDbConnection ()
{
+ libgda.gda_init ("System.Data.OleDb", "1.0", 0, new string [0]);
+ gdaConnection = IntPtr.Zero;
+ connectionTimeout = 15;
+ connectionString = null;
}
- public OleDbConnection (string connectionString)
- : this ()
+ public OleDbConnection (string connectionString) : this ()
{
this.connectionString = connectionString;
}
#region Properties
public string ConnectionString {
- get { return connectionString; }
- set { connectionString = value; }
+ get {
+ return connectionString;
+ }
+ set {
+ connectionString = value;
+ }
}
public int ConnectionTimeout {
- get { return connectionTimeout; }
+ get {
+ return connectionTimeout;
+ }
}
public string Database {
get {
- if (gdaConnection != IntPtr.Zero && libgda.gda_connection_is_open (gdaConnection)) {
+ if (gdaConnection != IntPtr.Zero
+ && libgda.gda_connection_is_open (gdaConnection)) {
return libgda.gda_connection_get_database (gdaConnection);
}
}
public string DataSource {
- [MonoTODO]
get {
- throw new NotImplementedException ();
+ if (gdaConnection != IntPtr.Zero
+ && libgda.gda_connection_is_open (gdaConnection)) {
+ return libgda.gda_connection_get_dsn (gdaConnection);
+ }
+
+ return null;
}
}
public string Provider {
get {
- if (gdaConnection != IntPtr.Zero && libgda.gda_connection_is_open (gdaConnection)) {
+ if (gdaConnection != IntPtr.Zero
+ && libgda.gda_connection_is_open (gdaConnection)) {
return libgda.gda_connection_get_provider (gdaConnection);
}
}
public string ServerVersion {
- [MonoTODO]
- get { throw new NotImplementedException (); }
+ get {
+ if (gdaConnection != IntPtr.Zero
+ && libgda.gda_connection_is_open (gdaConnection)) {
+ return libgda.gda_connection_get_server_version (gdaConnection);
+ }
+
+ return null;
+ }
}
public ConnectionState State
internal IntPtr GdaConnection
{
- get { return gdaConnection; }
+ get {
+ return gdaConnection;
+ }
}
-
+
#endregion // Properties
#region Methods
return null;
}
+ IDbTransaction IDbConnection.BeginTransaction ()
+ {
+ return BeginTransaction ();
+ }
+
public OleDbTransaction BeginTransaction (IsolationLevel level)
{
if (gdaConnection != IntPtr.Zero)
return null;
}
+ IDbTransaction IDbConnection.BeginTransaction (IsolationLevel level)
+ {
+ return BeginTransaction (level);
+ }
+
public void ChangeDatabase (string name)
{
- // FIXME: see http://bugzilla.gnome.org/show_bug.cgi?id=83315
+ if (gdaConnection == IntPtr.Zero)
+ throw new ArgumentException ();
+ if (State != ConnectionState.Open)
+ throw new InvalidOperationException ();
+
+ if (!libgda.gda_connection_change_database (gdaConnection, name))
+ throw new OleDbException (this);
}
public void Close ()
{
- if (gdaConnection != IntPtr.Zero) {
+ if (State == ConnectionState.Open) {
libgda.gda_connection_close (gdaConnection);
gdaConnection = IntPtr.Zero;
}
public OleDbCommand CreateCommand ()
{
- if (gdaConnection != IntPtr.Zero && libgda.gda_connection_is_open (gdaConnection))
- return new OleDbCommand ();
+ if (State == ConnectionState.Open)
+ return new OleDbCommand (null, this);
return null;
}
throw new NotImplementedException();
}
- [MonoTODO]
- IDbTransaction IDbConnection.BeginTransaction ()
- {
- throw new NotImplementedException ();
- }
-
- [MonoTODO]
- IDbTransaction IDbConnection.BeginTransaction (IsolationLevel level)
- {
- throw new NotImplementedException ();
- }
-
- [MonoTODO]
IDbCommand IDbConnection.CreateCommand ()
{
- throw new NotImplementedException ();
+ return CreateCommand ();
}
public void Open ()
{
- if (gdaConnection != IntPtr.Zero || libgda.gda_connection_is_open (gdaConnection))
+ string provider = "Default";
+ string gdaCncStr = "";
+ string[] args;
+ int len;
+ char [] separator = { ';' };
+
+ if (State == ConnectionState.Open)
throw new InvalidOperationException ();
- gdaConnection = libgda.gda_client_open_connection (libgda.GdaClient, connectionString, "", "");
+ gdaConnection = libgda.gda_client_open_connection (libgda.GdaClient,
+ connectionString,
+ "", "", 0);
+
+ /* convert the connection string to its GDA equivalent */
+ //args = connectionString.Split (';');
+ //len = args.Length;
+ //for (int i = 0; i < len; i++) {
+ // string[] values = args[i].Split (separator, 2);
+ // if (values[0] == "Provider") {
+ // if (values[1] == "SQLOLEDB")
+ // provider = "FreeTDS";
+ // else if (values[1] == "MSDAORA")
+ // provider = "Oracle";
+ // else if (values[2] == "Microsoft.Jet.OLEDB.4.0")
+ // provider = "MS Access";
+ // else
+ // provider = values[2];
+ // }
+ // else if (values[0] == "Addr" || values[0] == "Address")
+ // gdaCncStr = String.Concat (gdaCncStr, "HOST=", values[1], ";");
+ // else if (values[0] == "Database")
+ // gdaCncStr = String.Concat (gdaCncStr, "DATABASE=", values[1], ";");
+ // else if (values[0] == "Connection Lifetime")
+ // connectionTimeout = System.Convert.ToInt32 (values[1]);
+ // else if (values[0] == "File Name")
+ // gdaCncStr = String.Concat (gdaCncStr, "FILENAME=", values[1], ";");
+ // else if (values[0] == "Password" || values[0] == "Pwd")
+ // gdaCncStr = String.Concat (gdaCncStr, "PASSWORD=", values[1], ";");
+ // else if (values[0] == "User ID")
+ // gdaCncStr = String.Concat (gdaCncStr, "USERNAME=", values[1], ";");
+ //}
+
+ /* open the connection */
+ //System.Console.WriteLine ("Opening connection for provider " +
+ // provider + " with " + gdaCncStr);
+ //gdaConnection = libgda.gda_client_open_connection_from_string (libgda.GdaClient,
+ // provider,
+ // gdaCncStr);
}
[MonoTODO]
throw new NotImplementedException ();
}
- #endregion
-
- #region Internal Methods
-
- // Used to prevent OleDbConnection
- // from doing anything while
- // OleDbDataReader is open.
- // Open the Reader. (called from OleDbCommand)
- internal void OpenReader(OleDbDataReader reader)
- {
- if(dataReaderOpen == true) {
- // TODO: throw exception here?
- // because a reader
- // is already open
- }
- else {
- dataReader = reader;
- dataReaderOpen = true;
- }
- }
-
-
#endregion
#region Events and Delegates
projects / mono.git / blobdiff