// 
// TestOracleClient.cs - Tests Sytem.Data.OracleClient
//                       data provider in Mono.
//  
// Part of managed C#/.NET library System.Data.OracleClient.dll
//
// Part of the Mono class libraries at
// mcs/class/System.Data.OracleClient/System.Data.OracleClient.OCI
//
// Tests:
//     Assembly: System.Data.OracleClient.dll
//     Namespace: System.Data.OracleClient
// 
// Author: 
//     Daniel Morgan <danmorg@sc.rr.com>
//         
// Copyright (C) Daniel Morgan, 2002
// 

// Expected Results:
//    3 new rows where ENAME being: 'conn3', 'conn9', and 'conn1'

using System;
using System.Runtime.InteropServices;
using System.Data;
using System.Data.OracleClient;

namespace Test.OracleClient
{
	public class OracleTest
	{
		public OracleTest() 
		{

		}

		static void DoTest1(OracleConnection con, int conn) 
		{
			string inst = conn.ToString();

			string insertSql =
				"insert into scott.emp " +
				"(empno, ename, job, sal, deptno) " +
				"values(123" + inst + "," +
				"'conn" + inst + "'," +
				"'homy" + inst + "'," +
				"321" + inst + ",20)";
			
			Console.WriteLine("insertSql: " + insertSql);
			OracleCommand cmd = new OracleCommand();
			cmd.Connection = con;

			cmd.CommandText = insertSql;
			cmd.ExecuteNonQuery();

			if(conn == 2)
				cmd.CommandText = "rollback";
			else
				cmd.CommandText = "commit";
			cmd.ExecuteNonQuery();
		}

		static void DoTest9(OracleConnection con) {
			string inst = "9";

			string insertSql =
				"insert into scott.emp " +
				"(empno, ename, job, sal, deptno) " +
				"values(123" + inst + "," +
				"'conn" + inst + "'," +
				"'homy" + inst + "'," +
				"321" + inst + ",20)";
			
			Console.WriteLine("insertSql: " + insertSql);
			OracleCommand cmd = new OracleCommand();
			cmd.Connection = con;

			cmd.CommandText = insertSql;
			cmd.ExecuteNonQuery();

			cmd.CommandText = "commit";
			cmd.ExecuteNonQuery();
		}

		static void ReadSimpleTest(OracleConnection con) 
		{
			string selectSql = 
				"SELECT ename, job FROM scott.emp";
			OracleCommand cmd = new OracleCommand();
			cmd.Connection = con;
			cmd.CommandText = selectSql;
			OracleDataReader reader = cmd.ExecuteReader();
			Console.WriteLine("Results...");
			Console.WriteLine("Schema");
			DataTable table;
			table = reader.GetSchemaTable();
			for(int c = 0; c < reader.FieldCount; c++) {
				Console.WriteLine("  Column " + c.ToString());
				DataRow row = table.Rows[c];
			
				string ColumnName = (string) row["ColumnName"];
				string BaseColumnName = (string) row["BaseColumnName"];
				int ColumnSize = (int) row["ColumnSize"];
				int NumericScale = Convert.ToInt32( row["NumericScale"]);
				int NumericPrecision = Convert.ToInt32(row["NumericPrecision"]);
				Type DataType = (Type) row["DataType"];

				Console.WriteLine("    ColumnName: " + ColumnName);
				Console.WriteLine("    BaseColumnName: " + BaseColumnName);
				Console.WriteLine("    ColumnSize: " + ColumnSize.ToString());
				Console.WriteLine("    NumericScale: " + NumericScale.ToString());
				Console.WriteLine("    NumericPrecision: " + NumericPrecision.ToString());
				Console.WriteLine("    DataType: " + DataType.ToString());
			}

			int row = 0;
			Console.WriteLine("Data");
			while(reader.Read()) {
				row++;
				Console.WriteLine("  Row: " + row.ToString());
				for(int f = 0; f < reader.FieldCount; f++) {
					object ovalue;
					string svalue;
					ovalue = reader.GetValue(0);
					svalue = ovalue.ToString();
					Console.WriteLine("     Field: " + f.ToString());
					Console.WriteLine("         Value: " + svalue);
				}
			}
			if(row == 0)
				Console.WriteLine("No data returned.");
		}

		static void Wait(string msg) 
		{
			//Console.WriteLine(msg);
			//Console.WriteLine("Waiting...  Presee Enter to continue...");
			//string nothing = Console.ReadLine();
		}

		[STAThread]
		static void Main(string[] args)
		{	
			if(args.Length != 3) {
				Console.WriteLine("Usage: mono TestOracleClient database userid password");
				return;
			}

			string connectionString = String.Format(
				"Data Source={0};" +
				"User ID={1};" +
				"Password={2}",
				args[0], args[1], args[2]);

			Wait("Verify database.");

			OracleConnection con1 = new OracleConnection();
			con1.ConnectionString = connectionString;
			con1.Open();

			Wait("Verify 1 connection.");
			
			OracleConnection con2 = new OracleConnection();
			con2.ConnectionString = connectionString;
			con2.Open();
			
			Wait("Verify 2 connections.");

			OracleConnection con3 = new OracleConnection();
			con3.ConnectionString = connectionString;
			con3.Open();
			
			Wait("Verify 3 connections.");
					
			//DoTest1(con1, 1);
			//DoTest1(con2, 2);
			//DoTest1(con3, 3);
			
			//DoTest9(con1);
			
			Console.WriteLine ("Read Simple Test BEGIN...");
                        ReadSimpleTest(con1);
			Console.WriteLine ("Read Simple Test END.");

			Wait("Verify Proper Results.");
						
			con1.Close();		

			Wait("Verify 2 connections left.");

			con2.Close();

			Wait("Verify 1 connection left.");

			con3.Close();
			
			Wait("Verify all disconnected.");
		}
	}
}