[Quantproject-developers] QuantDownloader/Downloader TickerDownloader.cs, 1.22, 1.23

[Glauco S. <gla...@us...>]

Update of /cvsroot/quantproject/QuantDownloader/Downloader
In directory ddv4jf1.ch3.sourceforge.com:/tmp/cvs-serv17826/Downloader

Modified Files:
	TickerDownloader.cs 
Log Message:
Now both Access and MySql are supported

Index: TickerDownloader.cs
===================================================================
RCS file: /cvsroot/quantproject/QuantDownloader/Downloader/TickerDownloader.cs,v
retrieving revision 1.22
retrieving revision 1.23
diff -C2 -d -r1.22 -r1.23
*** TickerDownloader.cs	30 Nov 2008 22:52:04 -0000	1.22
--- TickerDownloader.cs	30 Dec 2008 00:18:26 -0000	1.23
***************
*** 2,5 ****
--- 2,6 ----
  using System.Threading;
  using System.Data;
+ using System.Data.Common;
  using System.IO;
  using System.Net;
***************
*** 16,20 ****
    public class TickerDownloader
    {
!     private System.Data.OleDb.OleDbConnection oleDbConnection1;
      private WebDownloader p_myForm;
      private int numOfTickersToDownload;
--- 17,21 ----
    public class TickerDownloader
    {
! //    private DbConnection dbConnection1;
      private WebDownloader p_myForm;
      private int numOfTickersToDownload;
***************
*** 37,41 ****
      private int numberOfQuotesInDatabase;
      private DataTable downloadedValuesFromSource;
!     private OleDbSingleTableAdapter adapter;
      private Stream stream;
      private StreamReader streamReader;
--- 38,42 ----
      private int numberOfQuotesInDatabase;
      private DataTable downloadedValuesFromSource;
!     private SingleTableDbDataAdapter adapter;
      private Stream stream;
      private StreamReader streamReader;
***************
*** 64,70 ****
      	p_myForm = myForm;
      	this.tickerDownloader_copyPropertiesFromForm( myForm );
!       this.oleDbConnection1 = myForm.OleDbConnection1;
        this.downloadedValuesFromSource = new DataTable("quotes");
!       this.adapter = new OleDbSingleTableAdapter("SELECT * FROM quotes WHERE 1=2",
                                                    this.downloadedValuesFromSource);
        this.downloadedValuesFromSource.Columns[Quotes.AdjustedCloseToCloseRatio].DefaultValue = 0;
--- 65,71 ----
      	p_myForm = myForm;
      	this.tickerDownloader_copyPropertiesFromForm( myForm );
! //      this.dbConnection1 = myForm.DbConnection1;
        this.downloadedValuesFromSource = new DataTable("quotes");
!       this.adapter = new SingleTableDbDataAdapter("SELECT * FROM quotes WHERE 1=2",
                                                    this.downloadedValuesFromSource);
        this.downloadedValuesFromSource.Columns[Quotes.AdjustedCloseToCloseRatio].DefaultValue = 0;
***************
*** 150,164 ****
      private void addTickerToFaultyTickers()
      {
!       System.Data.OleDb.OleDbCommand odc = new System.Data.OleDb.OleDbCommand();
!       odc.CommandText = "insert into faultyTickers ( ftTicker , ftDateTime ) " +
!         "values ( '" + currentTicker + "' , #" +
!         DateTime.Now.Month + "/" +
!         DateTime.Now.Day + "/" +
!         DateTime.Now.Year + " " +
!         DateTime.Now.Hour + "." +
!         DateTime.Now.Minute + "." +
!         DateTime.Now.Second + "# )";
!       odc.Connection = this.oleDbConnection1;
!       odc.ExecuteNonQuery();
      }
      
--- 151,175 ----
      private void addTickerToFaultyTickers()
      {
!     	string sqlNonQuery =
!     		"insert into faultyTickers ( ftTicker , ftDateTime ) " +
!     		"values ( '" + currentTicker + "' , #" +
!     		DateTime.Now.Month + "/" +
!     		DateTime.Now.Day + "/" +
!     		DateTime.Now.Year + " " +
!     		DateTime.Now.Hour + "." +
!     		DateTime.Now.Minute + "." +
!     		DateTime.Now.Second + "# )";
!     	SqlExecutor.ExecuteNonQuery( sqlNonQuery );
! //      System.Data.OleDb.OleDbCommand odc = new System.Data.OleDb.OleDbCommand();
! //      odc.CommandText = "insert into faultyTickers ( ftTicker , ftDateTime ) " +
! //        "values ( '" + currentTicker + "' , #" +
! //        DateTime.Now.Month + "/" +
! //        DateTime.Now.Day + "/" +
! //        DateTime.Now.Year + " " +
! //        DateTime.Now.Hour + "." +
! //        DateTime.Now.Minute + "." +
! //        DateTime.Now.Second + "# )";
! //      odc.Connection = this.dbConnection1;
! //      odc.ExecuteNonQuery();
      }
      
***************
*** 521,526 ****
        if(this.isComputeCloseToCloseRatioSelected)
          QuantProject.DataAccess.Tables.Quotes.ComputeCloseToCloseValues(this.downloadedValuesFromSource);
!       this.adapter.OleDbDataAdapter.ContinueUpdateOnError = true;
!       int rowsUpdated = this.adapter.OleDbDataAdapter.Update(this.downloadedValuesFromSource);
        if(rowsUpdated > 0)
        	this.updateCurrentStatusDatabaseUpdated("Added " + rowsUpdated.ToString() + " rows");
--- 532,537 ----
        if(this.isComputeCloseToCloseRatioSelected)
          QuantProject.DataAccess.Tables.Quotes.ComputeCloseToCloseValues(this.downloadedValuesFromSource);
!       this.adapter.DbDataAdapter.ContinueUpdateOnError = true;
!       int rowsUpdated = this.adapter.DbDataAdapter.Update(this.downloadedValuesFromSource);
        if(rowsUpdated > 0)
        	this.updateCurrentStatusDatabaseUpdated("Added " + rowsUpdated.ToString() + " rows");