using System;
using System.Data;
using System.Windows.Forms;
using sqlru.net;
using InterSystems.Data.CacheClient;
using InterSystems.Data.CacheTypes;

namespace NETTest
{
  public partial class Form1 : Form
  {
    public Form1()
    {
      InitializeComponent();
    }

    private void Button1Click(object sender, EventArgs e)
    {
      const string code = "5";
      var ts1 = new CacheDateTime(2011, 1, 01, 16, 0, 0);
      var ts2 = new CacheDateTime(2011, 2, 01, 16, 59, 59);
      var ds = new DataSet();
      using (var db = new CacheConnection("server=localhost;port=1972;namespace=USER;uid=_system;pwd=SYS"))
      {
        db.Open();
        try
        {
          Stock.KillExtent(db); // do ##class(net.Stock).%KillExtent()
          for (var i = 1; i <= 10; i++)
          {
            /*
             * for i=1:1:10
             * {
             *  set obj=##class(net.Stock).%New()
             *  set obj.Code="5"
             *  set obj.Minute.TimeStamp=$ZDT($NOW(),3,,3)
             *  set obj.Minute.TimeFrame=i
             *  set sc=obj.%Save(0)
             *  $$$ThrowOnError(sc)
             * }
             */
            var obj = new Stock(db) { Code = code, Minute = { TimeStamp = DateTime.Now, TimeFrame = i } };
            var sc = obj.Save(0);
            if (!sc.IsOK) sc.ThrowException();

            obj.Close();
          }

          using (var cmd = new CacheCommand("CALL net.Stock_Test1(?,?,?)", db))
          {
            cmd.Parameters.Add(new CacheParameter("code", code));
            cmd.Parameters.Add(new CacheParameter("ts1", ts1.Value));
            cmd.Parameters.Add(new CacheParameter("ts2", ts2.Value));
            using (var da = new CacheDataAdapter(cmd))
            {
              da.Fill(ds); //Имена таблиц: "Table","Table1","Table2"
            }
          }

          using (var cmd = Stock.Test3(db))
          {
            cmd.Parameters.Add(new CacheParameter("code", code));
            cmd.Parameters.Add(new CacheParameter("ts1", ts1.Value));
            cmd.Parameters.Add(new CacheParameter("ts2", ts2.Value));
            using (var da = new CacheDataAdapter(cmd))
            {
              da.Fill(ds, "Test3"); //Имя таблицы "Test3"
            }
          }

          var stream = new CacheBinaryStream(db);
          Stock.Test2(db, code, ts1.Value, ts2.Value, ref stream);
          ds.ReadXml(stream); //Имя таблицы "SQL"

          dataGrid1.DataSource = ds;
          dataGrid1.DataMember = null;

          MessageBox.Show(@"OK");
        }
        catch (Exception ex)
        {
          MessageBox.Show(ex.Message);
        }
      }
    }
  }
}