| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695 |
- //
- // 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
- //
- // To Compile:
- // mcs TestOracleClient.cs /r:System.Data.dll /r:System.Data.OracleClient.dll /nowarn:0168
- //
- // Author:
- // Daniel Morgan <[email protected]>
- //
- // Copyright (C) Daniel Morgan, 2002, 2004-2005
- //
- using System;
- using System.IO;
- using System.Runtime.InteropServices;
- using System.Data;
- using System.Data.OracleClient;
- using System.Text;
- using System.Threading;
- namespace Test.OracleClient
- {
- public class OracleTest
- {
- private static Thread t = null;
- private static string conStr;
- public static readonly int MAX_CONNECTIONS = 30; // max connections default to 100, but I will set to 30.
- public OracleTest()
- {
- }
- static void MonoTest(OracleConnection con)
- {
- Console.WriteLine (" Drop table MONO_ORACLE_TEST ...");
- try {
- OracleCommand cmd2 = con.CreateCommand ();
- cmd2.CommandText = "DROP TABLE MONO_ORACLE_TEST";
- cmd2.ExecuteNonQuery ();
- }
- catch (OracleException) {
- // ignore if table already exists
- }
- OracleCommand cmd = null;
- Console.WriteLine(" Creating table MONO_ORACLE_TEST...");
- cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.CommandText = "CREATE TABLE MONO_ORACLE_TEST ( " +
- " varchar2_value VarChar2(32), " +
- " long_value long, " +
- " number_whole_value Number(18), " +
- " number_scaled_value Number(18,2), " +
- " number_integer_value Integer, " +
- " float_value Float, " +
- " date_value Date, " +
- " char_value Char(32), " +
- " clob_value Clob, " +
- " blob_value Blob, " +
- " clob_empty_value Clob, " +
- " blob_empty_value Blob, " +
- " varchar2_null_value VarChar2(32), " +
- " number_whole_null_value Number(18), " +
- " number_scaled_null_value Number(18,2), " +
- " number_integer_null_value Integer, " +
- " float_null_value Float, " +
- " date_null_value Date, " +
- " char_null_value Char(32), " +
- " clob_null_value Clob, " +
- " blob_null_value Blob " +
- ")";
- cmd.ExecuteNonQuery();
- Console.WriteLine(" Begin Trans for table MONO_ORACLE_TEST...");
- OracleTransaction trans = con.BeginTransaction ();
- Console.WriteLine(" Inserting value into MONO_ORACLE_TEST...");
- cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.Transaction = trans;
- cmd.CommandText = "INSERT INTO mono_oracle_test " +
- " ( varchar2_value, " +
- " long_value, " +
- " number_whole_value, " +
- " number_scaled_value, " +
- " number_integer_value, " +
- " float_value, " +
- " date_value, " +
- " char_value, " +
- " clob_value, " +
- " blob_value, " +
- " clob_empty_value, " +
- " blob_empty_value " +
- ") " +
- " VALUES( " +
- " 'Mono', " +
- " 'This is a LONG column', " +
- " 123, " +
- " 456.78, " +
- " 8765, " +
- " 235.2, " +
- " TO_DATE( '2004-12-31', 'YYYY-MM-DD' ), " +
- " 'US', " +
- " EMPTY_CLOB(), " +
- " EMPTY_BLOB()," +
- " EMPTY_CLOB(), " +
- " EMPTY_BLOB()" +
- ")";
- cmd.ExecuteNonQuery();
- Console.WriteLine(" Select/Update CLOB columns on table MONO_ORACLE_TEST...");
- // update BLOB and CLOB columns
- OracleCommand select = con.CreateCommand ();
- select.Transaction = trans;
- select.CommandText = "SELECT CLOB_VALUE, BLOB_VALUE FROM MONO_ORACLE_TEST FOR UPDATE";
- OracleDataReader reader = select.ExecuteReader ();
- if (!reader.Read ())
- Console.WriteLine ("ERROR: RECORD NOT FOUND");
- // update clob_value
- Console.WriteLine(" Update CLOB column on table MONO_ORACLE_TEST...");
- OracleLob clob = reader.GetOracleLob (0);
- byte[] bytes = null;
- UnicodeEncoding encoding = new UnicodeEncoding ();
- bytes = encoding.GetBytes ("Mono is fun!");
- clob.Write (bytes, 0, bytes.Length);
- clob.Close ();
- // update blob_value
- Console.WriteLine(" Update BLOB column on table MONO_ORACLE_TEST...");
- OracleLob blob = reader.GetOracleLob (1);
- bytes = new byte[6] { 0x31, 0x32, 0x33, 0x34, 0x35, 0x036 };
- blob.Write (bytes, 0, bytes.Length);
- blob.Close ();
-
- Console.WriteLine(" Commit trans for table MONO_ORACLE_TEST...");
- trans.Commit ();
- // OracleCommand.ExecuteReader of MONO_ORACLE_TEST table
- Console.WriteLine(" Read simple test for table MONO_ORACLE_TEST...");
- ReadSimpleTest(con, "SELECT * FROM MONO_ORACLE_TEST");
- // OracleCommand.ExecuteScalar
- Console.WriteLine(" -ExecuteScalar tests...");
- string varchar2_value = (string) ReadScalar (con,"SELECT MAX(varchar2_value) FROM MONO_ORACLE_TEST");
- Console.WriteLine(" String Value: " + varchar2_value);
- Console.WriteLine(" Read Scalar: number_whole_value");
- decimal number_whole_value = (decimal)
- ReadScalar (con,"SELECT MAX(number_whole_value) FROM MONO_ORACLE_TEST");
- Console.WriteLine(" Int32 Value: " + number_whole_value.ToString());
- Console.WriteLine(" Read Scalar: number_scaled_value");
- decimal number_scaled_value = (decimal)
- ReadScalar (con,"SELECT number_scaled_value FROM MONO_ORACLE_TEST");
- Console.WriteLine(" Decimal Value: " + number_scaled_value.ToString());
-
- Console.WriteLine(" Read Scalar: date_value");
- DateTime date_value = (DateTime)
- ReadScalar (con,"SELECT date_value FROM MONO_ORACLE_TEST");
- Console.WriteLine(" DateTime Value: " + date_value.ToString());
-
- Console.WriteLine(" Read Scalar: clob_value");
- string clob_value = (string)
- ReadScalar (con,"SELECT clob_value FROM MONO_ORACLE_TEST");
- Console.WriteLine(" CLOB Value: " + clob_value);
- Console.WriteLine(" Read Scalar: blob_value");
- byte[] blob_value = (byte[])
- ReadScalar (con,"SELECT blob_value FROM MONO_ORACLE_TEST");
- string sblob_value = GetHexString (blob_value);
- Console.WriteLine(" BLOB Value: " + sblob_value);
-
- // OracleCommand.ExecuteOracleScalar
- Console.WriteLine(" -ExecuteOracleScalar tests...");
- Console.WriteLine(" Read Oracle Scalar: varchar2_value");
- ReadOracleScalar (con,"SELECT MAX(varchar2_value) FROM MONO_ORACLE_TEST");
- Console.WriteLine(" Read Oracle Scalar: number_whole_value");
- ReadOracleScalar (con,"SELECT MAX(number_whole_value) FROM MONO_ORACLE_TEST");
- Console.WriteLine(" Read Oracle Scalar: number_scaled_value");
- ReadOracleScalar (con,"SELECT number_scaled_value FROM MONO_ORACLE_TEST");
-
- Console.WriteLine(" Read Oracle Scalar: date_value");
- ReadOracleScalar (con,"SELECT date_value FROM MONO_ORACLE_TEST");
-
- Console.WriteLine(" Read Oracle Scalar: clob_value");
- ReadOracleScalar (con,"SELECT clob_value FROM MONO_ORACLE_TEST");
- Console.WriteLine(" Read Oracle Scalar: blob_value");
- ReadOracleScalar (con,"SELECT blob_value FROM MONO_ORACLE_TEST");
- }
- static object ReadScalar (OracleConnection con, string selectSql)
- {
- OracleCommand cmd = null;
- cmd = con.CreateCommand();
- cmd.CommandText = selectSql;
- object o = cmd.ExecuteScalar ();
- string dataType = o.GetType ().ToString ();
- Console.WriteLine (" DataType: " + dataType);
- return o;
- }
- static void ReadOracleScalar (OracleConnection con, string selectSql)
- {
- OracleCommand cmd = null;
- cmd = con.CreateCommand();
- cmd.CommandText = selectSql;
- object o = cmd.ExecuteOracleScalar ();
- string dataType = o.GetType ().ToString ();
- Console.WriteLine (" DataType: " + dataType);
- if (dataType.Equals("System.Data.OracleClient.OracleLob"))
- o = ((OracleLob) o).Value;
- if (o.GetType ().ToString ().Equals ("System.Byte[]"))
- o = GetHexString ((byte[])o);
-
- Console.WriteLine (" Value: " + o.ToString ());
- }
- static void ReadSimpleTest(OracleConnection con, string selectSql)
- {
- OracleCommand cmd = null;
- OracleDataReader reader = null;
-
- cmd = con.CreateCommand();
- cmd.CommandText = selectSql;
- 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 strColumnName = row["ColumnName"].ToString();
- string strBaseColumnName = row["BaseColumnName"].ToString();
- string strColumnSize = row["ColumnSize"].ToString();
- string strNumericScale = row["NumericScale"].ToString();
- string strNumericPrecision = row["NumericPrecision"].ToString();
- string strDataType = row["DataType"].ToString();
- Console.WriteLine(" ColumnName: " + strColumnName);
- Console.WriteLine(" BaseColumnName: " + strBaseColumnName);
- Console.WriteLine(" ColumnSize: " + strColumnSize);
- Console.WriteLine(" NumericScale: " + strNumericScale);
- Console.WriteLine(" NumericPrecision: " + strNumericPrecision);
- Console.WriteLine(" DataType: " + strDataType);
- }
- int r = 0;
- Console.WriteLine (" Data");
- while (reader.Read ()) {
- r++;
- Console.WriteLine (" Row: " + r.ToString ());
- for (int f = 0; f < reader.FieldCount; f++) {
- string sname = "";
- object ovalue = "";
- string svalue = "";
- string sDataType = "";
- string sFieldType = "";
- string sDataTypeName = "";
- string sOraDataType = "";
- sname = reader.GetName (f);
- if (reader.IsDBNull (f)) {
- ovalue = DBNull.Value;
- svalue = "";
- sDataType = "DBNull.Value";
- sOraDataType = "DBNull.Value";
- }
- else {
- //ovalue = reader.GetValue (f);
- ovalue = reader.GetOracleValue (f);
- object oravalue = null;
-
- sDataType = ovalue.GetType ().ToString ();
- switch (sDataType) {
- case "System.Data.OracleClient.OracleString":
- oravalue = ((OracleString) ovalue).Value;
- break;
- case "System.Data.OracleClient.OracleNumber":
- oravalue = ((OracleNumber) ovalue).Value;
- break;
- case "System.Data.OracleClient.OracleLob":
- OracleLob lob = (OracleLob) ovalue;
- oravalue = lob.Value;
- lob.Close ();
- break;
- case "System.Data.OracleClient.OracleDateTime":
- oravalue = ((OracleDateTime) ovalue).Value;
- break;
- case "System.Byte[]":
- oravalue = GetHexString((byte[])ovalue);
- break;
- case "System.Decimal":
- //Console.WriteLine(" *** Get Decimal, Int16, Int32, Int64, Float, Double, ...");
- decimal dec = reader.GetDecimal (f);
- //Console.WriteLine(" GetDecimal: " + dec.ToString ());
- oravalue = (object) dec;
- /*
- try {
- reader.GetInt16 (f);
- } catch (NotSupportedException e) {
- Console.WriteLine (" ** Expected exception caught for GetInt16: NotSupportedException: " + e.Message);
- }
- try {
- long lng = reader.GetInt64 (f);
- Console.WriteLine(" GetInt64: " + lng.ToString ());
- int n = reader.GetInt32 (f);
- Console.WriteLine(" GetInt32: " + n.ToString ());
- float flt = reader.GetFloat (f);
- Console.WriteLine(" GetFloat: " + flt.ToString ());
- double dbl = reader.GetDouble (f);
- Console.WriteLine(" GetDouble: " + dbl.ToString ());
- } catch (OverflowException oe1) {
- Console.WriteLine (" ** Overflow exception for numbers to big or too small: " + oe1.Message);
- }
- */
- break;
- default:
- oravalue = ovalue.ToString ();
- break;
- }
-
- sOraDataType = oravalue.GetType ().ToString ();
- if (sOraDataType.Equals ("System.Byte[]"))
- svalue = GetHexString ((byte[]) oravalue);
- else
- svalue = oravalue.ToString();
-
- }
- sFieldType = reader.GetFieldType(f).ToString();
- sDataTypeName = reader.GetDataTypeName(f);
- Console.WriteLine(" Field: " + f.ToString());
- Console.WriteLine(" Name: " + sname);
- Console.WriteLine(" Value: " + svalue);
- Console.WriteLine(" Oracle Data Type: " + sOraDataType);
- Console.WriteLine(" Data Type: " + sDataType);
- Console.WriteLine(" Field Type: " + sFieldType);
- Console.WriteLine(" Data Type Name: " + sDataTypeName);
- }
- }
- if(r == 0)
- Console.WriteLine(" No data returned.");
- }
-
- static void DataAdapterTest (OracleConnection connection)
- {
- Console.WriteLine(" Create select command...");
- OracleCommand command = connection.CreateCommand ();
- command.CommandText = "SELECT * FROM SCOTT.EMP";
- Console.WriteLine(" Create data adapter...");
- OracleDataAdapter adapter = new OracleDataAdapter (command);
- Console.WriteLine(" Create DataSet...");
- DataSet dataSet = new DataSet ("EMP");
- Console.WriteLine(" Fill DataSet via data adapter...");
- adapter.Fill (dataSet);
- Console.WriteLine(" Get DataTable...");
- DataTable table = dataSet.Tables [0];
- Console.WriteLine(" Display each row...");
- int rowCount = 0;
- foreach (DataRow row in table.Rows) {
- Console.WriteLine (" row {0}", rowCount + 1);
- for (int i = 0; i < table.Columns.Count; i += 1) {
- Console.WriteLine (" {0}: {1}", table.Columns [i].ColumnName, row [i]);
- }
- Console.WriteLine ();
- rowCount += 1;
- }
- }
- public static void DataAdapterTest2 (OracleConnection con)
- {
- DataAdapterTest2_Setup (con);
- ReadSimpleTest (con, "SELECT * FROM mono_adapter_test");
-
- GetMetaData (con, "SELECT * FROM mono_adapter_test");
- DataAdapterTest2_Insert (con);
- ReadSimpleTest (con, "SELECT * FROM mono_adapter_test");
-
- DataAdapterTest2_Update (con);
- ReadSimpleTest (con, "SELECT * FROM mono_adapter_test");
- DataAdapterTest2_Delete (con);
- ReadSimpleTest (con, "SELECT * FROM mono_adapter_test");
- }
- public static void GetMetaData (OracleConnection con, string sql)
- {
- OracleCommand cmd = null;
- OracleDataReader rdr = null;
-
- cmd = con.CreateCommand();
- cmd.CommandText = sql;
- Console.WriteLine("Read Schema With KeyInfo");
- rdr = cmd.ExecuteReader(CommandBehavior.KeyInfo | CommandBehavior.SchemaOnly);
-
- DataTable dt;
- dt = rdr.GetSchemaTable();
- foreach (DataRow schemaRow in dt.Rows) {
- foreach (DataColumn schemaCol in dt.Columns) {
- Console.WriteLine(schemaCol.ColumnName +
- " = " +
- schemaRow[schemaCol]);
- Console.WriteLine("---Type: " + schemaRow[schemaCol].GetType ().ToString());
- }
- Console.WriteLine("");
- }
- Console.WriteLine("Read Schema with No KeyInfo");
- rdr = cmd.ExecuteReader();
- dt = rdr.GetSchemaTable();
- foreach (DataRow schemaRow in dt.Rows) {
- foreach (DataColumn schemaCol in dt.Columns) {
- Console.WriteLine(schemaCol.ColumnName +
- " = " +
- schemaRow[schemaCol]);
- Console.WriteLine("---Type: " + schemaRow[schemaCol].GetType ().ToString());
- Console.WriteLine();
- }
- }
- }
- public static void DataAdapterTest2_Setup (OracleConnection con)
- {
- Console.WriteLine (" Drop table mono_adapter_test ...");
- try {
- OracleCommand cmd2 = con.CreateCommand ();
- cmd2.CommandText = "DROP TABLE mono_adapter_test";
- cmd2.ExecuteNonQuery ();
- }
- catch (OracleException) {
- // ignore if table already exists
- }
- OracleCommand cmd = null;
- int rowsAffected = 0;
- Console.WriteLine(" Creating table mono_adapter_test...");
- cmd = new OracleCommand ();
- cmd.Connection = con;
- cmd.CommandText = "CREATE TABLE mono_adapter_test ( " +
- " varchar2_value VarChar2(32), " +
- " number_whole_value Number(18) PRIMARY KEY, " +
- " number_scaled_value Number(18,2), " +
- " number_integer_value Integer, " +
- " float_value Float, " +
- " date_value Date, " +
- " clob_value Clob, " +
- " blob_value Blob ) ";
-
- // FIXME: char_value does not work
- /*
- cmd.CommandText = "CREATE TABLE mono_adapter_test ( " +
- " varchar2_value VarChar2(32), " +
- " number_whole_value Number(18) PRIMARY KEY, " +
- " number_scaled_value Number(18,2), " +
- " number_integer_value Integer, " +
- " float_value Float, " +
- " date_value Date, " +
- " char_value Char(32), " +
- " clob_value Clob, " +
- " blob_value Blob ) ";
- */
- rowsAffected = cmd.ExecuteNonQuery();
- Console.WriteLine(" Begin Trans for table mono_adapter_test...");
- OracleTransaction trans = con.BeginTransaction ();
- Console.WriteLine(" Inserting value into mono_adapter_test...");
- cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.Transaction = trans;
-
- cmd.CommandText = "INSERT INTO mono_adapter_test " +
- " ( varchar2_value, " +
- " number_whole_value, " +
- " number_scaled_value, " +
- " number_integer_value, " +
- " float_value, " +
- " date_value, " +
- " clob_value, " +
- " blob_value " +
- ") " +
- " VALUES( " +
- " 'Mono', " +
- " 11, " +
- " 456.78, " +
- " 8765, " +
- " 235.2, " +
- " TO_DATE( '2004-12-31', 'YYYY-MM-DD' ), " +
- " EMPTY_CLOB(), " +
- " EMPTY_BLOB() " +
- ")";
- /*
- cmd.CommandText = "INSERT INTO mono_adapter_test " +
- " ( varchar2_value, " +
- " number_whole_value, " +
- " number_scaled_value, " +
- " number_integer_value, " +
- " float_value, " +
- " date_value, " +
- " char_value, " +
- " clob_value, " +
- " blob_value " +
- ") " +
- " VALUES( " +
- " 'Mono', " +
- " 11, " +
- " 456.78, " +
- " 8765, " +
- " 235.2, " +
- " TO_DATE( '2004-12-31', 'YYYY-MM-DD' ), " +
- " 'US', " +
- " EMPTY_CLOB(), " +
- " EMPTY_BLOB() " +
- ")";
- */
- rowsAffected = cmd.ExecuteNonQuery();
- Console.WriteLine(" Select/Update CLOB columns on table mono_adapter_test...");
-
- // update BLOB and CLOB columns
- OracleCommand select = con.CreateCommand ();
- select.Transaction = trans;
- select.CommandText = "SELECT CLOB_VALUE, BLOB_VALUE FROM mono_adapter_test FOR UPDATE";
- OracleDataReader reader = select.ExecuteReader ();
- if (!reader.Read ())
- Console.WriteLine ("ERROR: RECORD NOT FOUND");
-
- // update clob_value
- Console.WriteLine(" Update CLOB column on table mono_adapter_test...");
- OracleLob clob = reader.GetOracleLob (0);
- byte[] bytes = null;
- UnicodeEncoding encoding = new UnicodeEncoding ();
- bytes = encoding.GetBytes ("Mono is fun!");
- clob.Write (bytes, 0, bytes.Length);
- clob.Close ();
-
- // update blob_value
- Console.WriteLine(" Update BLOB column on table mono_adapter_test...");
- OracleLob blob = reader.GetOracleLob (1);
- bytes = new byte[6] { 0x31, 0x32, 0x33, 0x34, 0x35, 0x036 };
- blob.Write (bytes, 0, bytes.Length);
- blob.Close ();
-
- Console.WriteLine(" Commit trans for table mono_adapter_test...");
- trans.Commit ();
- CommitCursor (con);
- }
- public static void DataAdapterTest2_Insert (OracleConnection con)
- {
- Console.WriteLine("================================");
- Console.WriteLine("=== Adapter Insert =============");
- Console.WriteLine("================================");
- OracleTransaction transaction = con.BeginTransaction ();
-
- Console.WriteLine(" Create adapter...");
- OracleDataAdapter da = new OracleDataAdapter("select * from mono_adapter_test", con);
- da.SelectCommand.Transaction = transaction;
-
- Console.WriteLine(" Create command builder...");
- OracleCommandBuilder mycb = new OracleCommandBuilder(da);
- Console.WriteLine(" Create data set ...");
- DataSet ds = new DataSet();
-
- Console.WriteLine(" Fill data set via adapter...");
- da.Fill(ds, "mono_adapter_test");
- Console.WriteLine(" New Row...");
- DataRow myRow;
- myRow = ds.Tables["mono_adapter_test"].NewRow();
- byte[] bytes = new byte[] { 0x45,0x46,0x47,0x48,0x49,0x50 };
- Console.WriteLine(" Set values in the new DataRow...");
- myRow["varchar2_value"] = "OracleClient";
- myRow["number_whole_value"] = 22;
- myRow["number_scaled_value"] = 12.34;
- myRow["number_integer_value"] = 456;
- myRow["float_value"] = 98.76;
- myRow["date_value"] = new DateTime(2001,07,09);
- Console.WriteLine(" *** FIXME; char value not working");
- //myRow["char_value"] = "Romeo";
- myRow["clob_value"] = "clobtest";
- myRow["blob_value"] = bytes;
-
- Console.WriteLine(" Add DataRow to DataTable...");
- ds.Tables["mono_adapter_test"].Rows.Add(myRow);
- Console.WriteLine("da.Update(ds...");
- da.Update(ds, "mono_adapter_test");
- transaction.Commit();
- }
- public static void DataAdapterTest2_Update (OracleConnection con)
- {
- Console.WriteLine("================================");
- Console.WriteLine("=== Adapter Update =============");
- Console.WriteLine("================================");
- OracleTransaction transaction = con.BeginTransaction ();
- Console.WriteLine(" Create adapter...");
- OracleCommand selectCmd = con.CreateCommand ();
- selectCmd.Transaction = transaction;
- selectCmd.CommandText = "SELECT * FROM mono_adapter_test";
- OracleDataAdapter da = new OracleDataAdapter(selectCmd);
- Console.WriteLine(" Create command builder...");
- OracleCommandBuilder mycb = new OracleCommandBuilder(da);
- Console.WriteLine(" Create data set ...");
- DataSet ds = new DataSet();
- Console.WriteLine(" Set missing schema action...");
-
- Console.WriteLine(" Fill data set via adapter...");
- da.Fill(ds, "mono_adapter_test");
- DataRow myRow;
- Console.WriteLine(" New Row...");
- myRow = ds.Tables["mono_adapter_test"].Rows[0];
- Console.WriteLine("Tables Count: " + ds.Tables.Count.ToString());
- DataTable table = ds.Tables["mono_adapter_test"];
- DataRowCollection rows;
- rows = table.Rows;
- Console.WriteLine(" Row Count: " + rows.Count.ToString());
- myRow = rows[0];
- byte[] bytes = new byte[] { 0x62,0x63,0x64,0x65,0x66,0x67 };
- Console.WriteLine(" Set values in the new DataRow...");
- myRow["varchar2_value"] = "Super Power!";
-
- myRow["number_scaled_value"] = 12.35;
- myRow["number_integer_value"] = 457;
- myRow["float_value"] = 198.76;
- myRow["date_value"] = new DateTime(2002,08,09);
- //myRow["char_value"] = "Juliet";
- myRow["clob_value"] = "this is a clob";
- myRow["blob_value"] = bytes;
- Console.WriteLine("da.Update(ds...");
- da.Update(ds, "mono_adapter_test");
- transaction.Commit();
- }
- public static void DataAdapterTest2_Delete (OracleConnection con)
- {
- Console.WriteLine("================================");
- Console.WriteLine("=== Adapter Delete =============");
- Console.WriteLine("================================");
- OracleTransaction transaction = con.BeginTransaction ();
-
- Console.WriteLine(" Create adapter...");
- OracleDataAdapter da = new OracleDataAdapter("SELECT * FROM mono_adapter_test", con);
- Console.WriteLine(" Create command builder...");
- OracleCommandBuilder mycb = new OracleCommandBuilder(da);
- Console.WriteLine(" set transr...");
- da.SelectCommand.Transaction = transaction;
- Console.WriteLine(" Create data set ...");
- DataSet ds = new DataSet();
-
- Console.WriteLine("Fill data set via adapter...");
- da.Fill(ds, "mono_adapter_test");
- Console.WriteLine("delete row...");
- ds.Tables["mono_adapter_test"].Rows[0].Delete();
- Console.WriteLine("da.Update(table...");
- da.Update(ds, "mono_adapter_test");
- Console.WriteLine("Commit...");
- transaction.Commit();
- }
- static void TestNonQueryUsingExecuteReader(OracleConnection con)
- {
- OracleDataReader reader = null;
- OracleTransaction trans = null;
- Console.WriteLine(" drop table mono_adapter_test...");
- OracleCommand cmd = con.CreateCommand();
- cmd.CommandText = "DROP TABLE MONO_ADAPTER_TEST";
- trans = con.BeginTransaction();
- cmd.Transaction = trans;
- try {
- reader = cmd.ExecuteReader();
- Console.WriteLine(" RowsAffected before read: " + reader.RecordsAffected.ToString());
- reader.Read();
- Console.WriteLine(" RowsAffected after read: " + reader.RecordsAffected.ToString());
- reader.Close();
- Console.WriteLine(" RowsAffected after close: " + reader.RecordsAffected.ToString());
- trans.Commit();
- }
- catch(OracleException e) {
- Console.WriteLine(" OracleException caught: " + e.Message);
- trans.Commit();
- }
- Console.WriteLine(" Create table mono_adapter_test...");
- cmd.CommandText = "CREATE TABLE MONO_ADAPTER_TEST ( " +
- " varchar2_value VarChar2(32), " +
- " number_whole_value Number(18,0) PRIMARY KEY ) ";
- trans = con.BeginTransaction();
- cmd.Transaction = trans;
- reader = cmd.ExecuteReader();
- Console.WriteLine(" RowsAffected before read: " + reader.RecordsAffected.ToString());
- reader.Read();
- Console.WriteLine(" RowsAffected after read: " + reader.RecordsAffected.ToString());
- reader.Close();
- Console.WriteLine(" RowsAffected after close: " + reader.RecordsAffected.ToString());
- trans.Commit();
- Console.WriteLine("Insert into table mono_adapter_test...");
-
- string sql =
- "INSERT INTO MONO_ADAPTER_TEST " +
- "(VARCHAR2_VALUE,NUMBER_WHOLE_VALUE) " +
- "VALUES(:p1,:p2)";
- OracleCommand cmd2 = con.CreateCommand();
- trans = con.BeginTransaction();
- cmd2.Transaction = trans;
- cmd2.CommandText = sql;
-
- OracleParameter myParameter1 = new OracleParameter("p1", OracleType.VarChar, 32);
- myParameter1.Direction = ParameterDirection.Input;
-
- OracleParameter myParameter2 = new OracleParameter("p2", OracleType.Number);
- myParameter2.Direction = ParameterDirection.Input;
- myParameter2.Value = 182;
- myParameter1.Value = "Mono";
- cmd2.Parameters.Add (myParameter1);
- cmd2.Parameters.Add (myParameter2);
-
- // insert 1 record
- reader = cmd2.ExecuteReader();
- Console.WriteLine(" RowsAffected before read: " + reader.RecordsAffected.ToString());
- reader.Read();
- Console.WriteLine(" RowsAffected after read: " + reader.RecordsAffected.ToString());
- reader.Close();
- Console.WriteLine(" RowsAffected after close: " + reader.RecordsAffected.ToString());
- // insert another record
- Console.WriteLine(" Insert another record...");
- myParameter2.Value = 183;
- myParameter1.Value = "Oracle";
- reader = cmd2.ExecuteReader();
- Console.WriteLine(" RowsAffected before read: " + reader.RecordsAffected.ToString());
- reader.Read();
- Console.WriteLine(" RowsAffected after read: " + reader.RecordsAffected.ToString());
- reader.Close();
- Console.WriteLine(" RowsAffected after close: " + reader.RecordsAffected.ToString());
- trans.Commit();
- trans = null;
-
- ReadSimpleTest(con, "SELECT * FROM MONO_ADAPTER_TEST");
- }
- static void CommitCursor (OracleConnection con)
- {
- OracleCommand cmd = con.CreateCommand ();
- cmd.CommandText = "COMMIT";
- cmd.ExecuteNonQuery ();
- cmd.Dispose ();
- cmd = null;
- }
- static void RollbackTest (OracleConnection connection)
- {
- OracleTransaction transaction = connection.BeginTransaction ();
- OracleCommand insert = connection.CreateCommand ();
- insert.Transaction = transaction;
- insert.CommandText = "INSERT INTO SCOTT.EMP (EMPNO, ENAME, JOB) VALUES (8787, 'T Coleman', 'Monoist')";
- Console.WriteLine (" Inserting record ...");
- insert.ExecuteNonQuery ();
- OracleCommand select = connection.CreateCommand ();
- select.CommandText = "SELECT COUNT(*) FROM SCOTT.EMP WHERE EMPNO = 8787";
- select.Transaction = transaction;
- OracleDataReader reader = select.ExecuteReader ();
- reader.Read ();
- Console.WriteLine (" Row count SHOULD BE 1, VALUE IS {0}", reader.GetValue (0));
- reader.Close ();
- Console.WriteLine (" Rolling back transaction ...");
- transaction.Rollback ();
- select = connection.CreateCommand ();
- select.CommandText = "SELECT COUNT(*) FROM SCOTT.EMP WHERE EMPNO = 8787";
- reader = select.ExecuteReader ();
- reader.Read ();
- Console.WriteLine (" Row count SHOULD BE 0, VALUE IS {0}", reader.GetValue (0));
- reader.Close ();
- }
-
- static void CommitTest (OracleConnection connection)
- {
- OracleTransaction transaction = connection.BeginTransaction ();
- OracleCommand insert = connection.CreateCommand ();
- insert.Transaction = transaction;
- insert.CommandText = "INSERT INTO SCOTT.EMP (EMPNO, ENAME, JOB) VALUES (8787, 'T Coleman', 'Monoist')";
- Console.WriteLine (" Inserting record ...");
- insert.ExecuteNonQuery ();
- OracleCommand select = connection.CreateCommand ();
- select.CommandText = "SELECT COUNT(*) FROM SCOTT.EMP WHERE EMPNO = 8787";
- select.Transaction = transaction;
- Console.WriteLine (" Row count SHOULD BE 1, VALUE IS {0}", select.ExecuteScalar ());
- Console.WriteLine (" Committing transaction ...");
- transaction.Commit ();
- select = connection.CreateCommand ();
- select.CommandText = "SELECT COUNT(*) FROM SCOTT.EMP WHERE EMPNO = 8787";
- Console.WriteLine ("Row count SHOULD BE 1, VALUE IS {0}", select.ExecuteScalar ());
- transaction = connection.BeginTransaction ();
- OracleCommand delete = connection.CreateCommand ();
- delete.Transaction = transaction;
- delete.CommandText = "DELETE FROM SCOTT.EMP WHERE EMPNO = 8787";
- delete.ExecuteNonQuery ();
- transaction.Commit ();
- }
- public static void ParameterTest2 (OracleConnection connection)
- {
- Console.WriteLine(" Setting NLS_DATE_FORMAT...");
- OracleCommand cmd2 = connection.CreateCommand();
- cmd2.CommandText = "ALTER SESSION SET NLS_DATE_FORMAT = 'YYYY-MM-DD HH24:MI:SS'";
-
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" Drop table MONO_TEST_TABLE2...");
- try {
- cmd2.CommandText = "DROP TABLE MONO_TEST_TABLE7";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine(" Create table MONO_TEST_TABLE7...");
- cmd2.CommandText = "CREATE TABLE MONO_TEST_TABLE7(" +
- " COL1 VARCHAR2(8) NOT NULL, " +
- " COL2 VARCHAR2(32), " +
- " COL3 NUMBER(18,2), " +
- " COL4 NUMBER(18,2), " +
- " COL5 DATE NOT NULL, " +
- " COL6 DATE, " +
- " COL7 BLOB NOT NULL, " +
- " COL8 BLOB, " +
- " COL9 CLOB NOT NULL, " +
- " COL10 CLOB " +
- ")";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" create insert command...");
- OracleTransaction trans = connection.BeginTransaction ();
- OracleCommand cmd = connection.CreateCommand ();
- cmd.Transaction = trans;
- cmd.CommandText = "INSERT INTO MONO_TEST_TABLE7 " +
- "(COL1,COL2,COL3,COL4,COL5,COL6,COL7,COL8,COL9,COL10) " +
- "VALUES(:P1,:P2,:P3,:P4,:P5,:P6,:P7,:P8,:P9,:P10)";
-
- Console.WriteLine(" Add parameters...");
- OracleParameter parm1 = cmd.Parameters.Add (":P1", OracleType.VarChar, 8);
- OracleParameter parm2 = cmd.Parameters.Add (":P2", OracleType.VarChar, 32);
-
- OracleParameter parm3 = cmd.Parameters.Add (":P3", OracleType.Number);
- OracleParameter parm4 = cmd.Parameters.Add (":P4", OracleType.Number);
-
- OracleParameter parm5 = cmd.Parameters.Add (":P5", OracleType.DateTime);
- OracleParameter parm6 = cmd.Parameters.Add (":P6", OracleType.DateTime);
- // FIXME: fix BLOBs and CLOBs in OracleParameter
- OracleParameter parm7 = cmd.Parameters.Add (":P7", OracleType.Blob);
- OracleParameter parm8 = cmd.Parameters.Add (":P8", OracleType.Blob);
- OracleParameter parm9 = cmd.Parameters.Add (":P9", OracleType.Clob);
- OracleParameter parm10 = cmd.Parameters.Add (":P10", OracleType.Clob);
- // TODO: implement out, return, and ref parameters
- string s = "Mono";
- decimal d = 123456789012345.678M;
- DateTime dt = DateTime.Now;
- string clob = "Clob";
- byte[] blob = new byte[] { 0x31, 0x32, 0x33, 0x34, 0x35 };
-
- Console.WriteLine(" Set Values...");
- parm1.Value = s;
- parm2.Value = DBNull.Value;
-
- parm3.Value = d;
- parm4.Value = DBNull.Value;
-
- parm5.Value = dt;
- parm6.Value = DBNull.Value;
-
- parm7.Value = blob;
- parm8.Value = DBNull.Value;
- parm9.Value = clob;
- parm10.Value = DBNull.Value;
-
- Console.WriteLine(" ExecuteNonQuery...");
- cmd.ExecuteNonQuery ();
- trans.Commit();
- }
- public static void ParameterTest (OracleConnection connection)
- {
- Console.WriteLine(" Setting NLS_DATE_FORMAT...");
- OracleCommand cmd2 = connection.CreateCommand();
- cmd2.CommandText = "ALTER SESSION SET NLS_DATE_FORMAT = 'YYYY-MM-DD HH24:MI:SS'";
-
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" Drop table MONO_TEST_TABLE2...");
- try {
- cmd2.CommandText = "DROP TABLE MONO_TEST_TABLE7";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine(" Create table MONO_TEST_TABLE7...");
- cmd2.CommandText = "CREATE TABLE MONO_TEST_TABLE7(" +
- " COL1 VARCHAR2(8) NOT NULL, " +
- " COL2 VARCHAR2(32), " +
- " COL3 NUMBER(18,2) NOT NULL, " +
- " COL4 NUMBER(18,2), " +
- " COL5 DATE NOT NULL, " +
- " COL6 DATE, " +
- " COL7 BLOB NOT NULL, " +
- " COL8 BLOB, " +
- " COL9 CLOB NOT NULL, " +
- " COL10 CLOB " +
- ")";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" create insert command...");
- OracleTransaction trans = connection.BeginTransaction ();
- OracleCommand cmd = connection.CreateCommand ();
- cmd.Transaction = trans;
- cmd.CommandText = "INSERT INTO MONO_TEST_TABLE7 " +
- "(COL1,COL2,COL3,COL4,COL5,COL6,COL7,COL8,COL9,COL10) " +
- "VALUES(:P1,:P2,:P3,:P4,:P5,:P6,:P7,:P8,:P9,:P10)";
-
- Console.WriteLine(" Add parameters...");
- OracleParameter parm1 = cmd.Parameters.Add (":P1", OracleType.VarChar, 8);
- OracleParameter parm2 = cmd.Parameters.Add (":P2", OracleType.VarChar, 32);
-
- OracleParameter parm3 = cmd.Parameters.Add (":P3", OracleType.Number);
- OracleParameter parm4 = cmd.Parameters.Add (":P4", OracleType.Number);
-
- OracleParameter parm5 = cmd.Parameters.Add (":P5", OracleType.DateTime);
- OracleParameter parm6 = cmd.Parameters.Add (":P6", OracleType.DateTime);
- // FIXME: fix BLOBs and CLOBs in OracleParameter
- OracleParameter parm7 = cmd.Parameters.Add (":P7", OracleType.Blob);
- OracleParameter parm8 = cmd.Parameters.Add (":P8", OracleType.Blob);
- OracleParameter parm9 = cmd.Parameters.Add (":P9", OracleType.Clob);
- OracleParameter parm10 = cmd.Parameters.Add (":P10", OracleType.Clob);
- // TODO: implement out, return, and ref parameters
- string s = "Mono";
- decimal d = 123456789012345.678M;
- DateTime dt = DateTime.Now;
- string clob = "Clob";
- byte[] blob = new byte[] { 0x31, 0x32, 0x33, 0x34, 0x35 };
-
- Console.WriteLine(" Set Values...");
- parm1.Value = s;
- parm2.Value = DBNull.Value;
-
- parm3.Value = d;
- parm4.Value = DBNull.Value;
-
- parm5.Value = dt;
- parm6.Value = DBNull.Value;
-
- parm7.Value = blob;
- parm8.Value = DBNull.Value;
- parm9.Value = clob;
- parm10.Value = DBNull.Value;
-
- Console.WriteLine(" ExecuteNonQuery...");
- cmd.ExecuteNonQuery ();
- trans.Commit();
- }
- public static void CLOBTest (OracleConnection connection)
- {
- Console.WriteLine (" BEGIN TRANSACTION ...");
- OracleTransaction transaction = connection.BeginTransaction ();
- Console.WriteLine (" Drop table CLOBTEST ...");
- try {
- OracleCommand cmd2 = connection.CreateCommand ();
- cmd2.Transaction = transaction;
- cmd2.CommandText = "DROP TABLE CLOBTEST";
- cmd2.ExecuteNonQuery ();
- }
- catch (OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine (" CREATE TABLE ...");
- OracleCommand create = connection.CreateCommand ();
- create.Transaction = transaction;
- create.CommandText = "CREATE TABLE CLOBTEST (CLOB_COLUMN CLOB)";
- create.ExecuteNonQuery ();
- Console.WriteLine (" INSERT RECORD ...");
- OracleCommand insert = connection.CreateCommand ();
- insert.Transaction = transaction;
- insert.CommandText = "INSERT INTO CLOBTEST VALUES (EMPTY_CLOB())";
- insert.ExecuteNonQuery ();
- OracleCommand select = connection.CreateCommand ();
- select.Transaction = transaction;
- select.CommandText = "SELECT CLOB_COLUMN FROM CLOBTEST FOR UPDATE";
- Console.WriteLine (" SELECTING A CLOB (CHARACTER) VALUE FROM CLOBTEST");
- OracleDataReader reader = select.ExecuteReader ();
- if (!reader.Read ())
- Console.WriteLine ("ERROR: RECORD NOT FOUND");
- Console.WriteLine (" TESTING OracleLob OBJECT ...");
- OracleLob lob = reader.GetOracleLob (0);
- Console.WriteLine (" LENGTH: {0}", lob.Length);
- Console.WriteLine (" CHUNK SIZE: {0}", lob.ChunkSize);
- UnicodeEncoding encoding = new UnicodeEncoding ();
- byte[] value = new byte [lob.Length * 2];
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- Console.WriteLine (" UPDATING VALUE TO 'TEST ME!'");
- value = encoding.GetBytes ("TEST ME!");
- lob.Write (value, 0, value.Length);
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- Console.WriteLine (" RE-READ VALUE...");
- lob.Seek (1, SeekOrigin.Begin);
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- value = new byte [lob.Length * 2];
- lob.Read (value, 0, value.Length);
- Console.WriteLine (" VALUE: {0}", encoding.GetString (value));
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- Console.WriteLine (" CLOSE OracleLob...");
- lob.Close ();
- Console.WriteLine (" CLOSING READER...");
-
- reader.Close ();
- transaction.Commit ();
- }
- public static void BLOBTest (OracleConnection connection)
- {
- Console.WriteLine (" BEGIN TRANSACTION ...");
- OracleTransaction transaction = connection.BeginTransaction ();
- Console.WriteLine (" Drop table BLOBTEST ...");
- try {
- OracleCommand cmd2 = connection.CreateCommand ();
- cmd2.Transaction = transaction;
- cmd2.CommandText = "DROP TABLE BLOBTEST";
- cmd2.ExecuteNonQuery ();
- }
- catch (OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine (" CREATE TABLE ...");
- OracleCommand create = connection.CreateCommand ();
- create.Transaction = transaction;
- create.CommandText = "CREATE TABLE BLOBTEST (BLOB_COLUMN BLOB)";
- create.ExecuteNonQuery ();
- Console.WriteLine (" INSERT RECORD ...");
- OracleCommand insert = connection.CreateCommand ();
- insert.Transaction = transaction;
- insert.CommandText = "INSERT INTO BLOBTEST VALUES (EMPTY_BLOB())";
- insert.ExecuteNonQuery ();
- OracleCommand select = connection.CreateCommand ();
- select.Transaction = transaction;
- select.CommandText = "SELECT BLOB_COLUMN FROM BLOBTEST FOR UPDATE";
- Console.WriteLine (" SELECTING A BLOB (Binary) VALUE FROM BLOBTEST");
- OracleDataReader reader = select.ExecuteReader ();
- if (!reader.Read ())
- Console.WriteLine ("ERROR: RECORD NOT FOUND");
- Console.WriteLine (" TESTING OracleLob OBJECT ...");
- OracleLob lob = reader.GetOracleLob (0);
-
- byte[] value = null;
- string bvalue = "";
- Console.WriteLine (" UPDATING VALUE");
- byte[] bytes = new byte[6];
- bytes[0] = 0x31;
- bytes[1] = 0x32;
- bytes[2] = 0x33;
- bytes[3] = 0x34;
- bytes[4] = 0x35;
- bytes[5] = 0x36;
- lob.Write (bytes, 0, bytes.Length);
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- Console.WriteLine (" RE-READ VALUE...");
- lob.Seek (1, SeekOrigin.Begin);
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- value = new byte [lob.Length];
- lob.Read (value, 0, value.Length);
-
- bvalue = "";
- if (value.GetType ().ToString ().Equals ("System.Byte[]"))
- bvalue = GetHexString (value);
- Console.WriteLine (" Bytes: " + bvalue);
- Console.WriteLine (" CURRENT POSITION: {0}", lob.Position);
- Console.WriteLine (" CLOSE OracleLob...");
- lob.Close ();
- Console.WriteLine (" CLOSING READER...");
-
- reader.Close ();
- transaction.Commit ();
- }
- static void Wait(string msg)
- {
- Console.WriteLine(msg);
- if (msg.Equals(""))
- Console.WriteLine("Waiting... Press Enter to continue...");
- Console.ReadLine();
- }
- // use this function to read a byte array into a string
- // for easy display of binary data, such as, a BLOB value
- public static string GetHexString (byte[] bytes)
- {
- string bvalue = "";
-
- StringBuilder sb2 = new StringBuilder();
- for (int z = 0; z < bytes.Length; z++) {
- byte byt = bytes[z];
- if (byt < 0x10)
- sb2.Append ("0");
- sb2.Append (byt.ToString("x"));
- }
- if (sb2.Length > 0)
- bvalue = "0x" + sb2.ToString ();
-
- return bvalue;
- }
- static void StoredProcedureTest1 (OracleConnection con)
- {
- // test stored procedure with no parameters
-
-
- OracleCommand cmd2 = con.CreateCommand ();
- Console.WriteLine(" Drop table MONO_TEST_TABLE1...");
- try {
- cmd2.CommandText = "DROP TABLE MONO_TEST_TABLE1";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if table did not exist
- }
- Console.WriteLine(" Drop procedure SP_TEST1...");
- try {
- cmd2.CommandText = "DROP PROCEDURE SP_TEST1";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if procedure did not exist
- }
- Console.WriteLine(" Create table MONO_TEST_TABLE1...");
- cmd2.CommandText = "CREATE TABLE MONO_TEST_TABLE1 (" +
- " COL1 VARCHAR2(8), "+
- " COL2 VARCHAR2(32))";
- cmd2.ExecuteNonQuery ();
-
- Console.WriteLine(" Create stored procedure SP_TEST1...");
- cmd2.CommandText = "CREATE PROCEDURE SP_TEST1 " +
- " IS " +
- " BEGIN " +
- " INSERT INTO MONO_TEST_TABLE1 (COL1,COL2) VALUES ('aaa','bbbb');" +
- " COMMIT;" +
- " END;";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine("COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" Call stored procedure sp_test1...");
- OracleCommand cmd3 = con.CreateCommand ();
- cmd3.CommandType = CommandType.StoredProcedure;
- cmd3.CommandText = "sp_test1";
- cmd3.ExecuteNonQuery ();
- }
- static void StoredProcedureTest2 (OracleConnection con)
- {
- // test stored procedure with 2 parameters
- Console.WriteLine(" Drop table MONO_TEST_TABLE2...");
- OracleCommand cmd2 = con.CreateCommand ();
- try {
- cmd2.CommandText = "DROP TABLE MONO_TEST_TABLE2";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine(" Drop procedure SP_TEST2...");
- try {
- cmd2.CommandText = "DROP PROCEDURE SP_TEST2";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if procedure does not exists
- }
- Console.WriteLine(" Create table MONO_TEST_TABLE2...");
-
- cmd2.CommandText = "CREATE TABLE MONO_TEST_TABLE2 (" +
- " COL1 VARCHAR2(8), "+
- " COL2 VARCHAR2(32))";
- cmd2.ExecuteNonQuery ();
-
- Console.WriteLine(" Create stored procedure SP_TEST2...");
- cmd2.CommandText = "CREATE PROCEDURE SP_TEST2(parm1 VARCHAR2,parm2 VARCHAR2) " +
- " IS " +
- " BEGIN " +
- " INSERT INTO MONO_TEST_TABLE2 (COL1,COL2) VALUES (parm1,parm2);" +
- " COMMIT;" +
- " END;";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" Call stored procedure SP_TEST2 with two parameters...");
- OracleCommand cmd3 = con.CreateCommand ();
- cmd3.CommandType = CommandType.StoredProcedure;
- cmd3.CommandText = "sp_test2";
- OracleParameter myParameter1 = new OracleParameter("parm1", OracleType.VarChar);
- myParameter1.Value = "yyy13";
- myParameter1.Size = 8;
- myParameter1.Direction = ParameterDirection.Input;
-
- OracleParameter myParameter2 = new OracleParameter("parm2", OracleType.VarChar);
- myParameter2.Value = "iii13";
- myParameter2.Size = 32;
- myParameter2.Direction = ParameterDirection.Input;
- cmd3.Parameters.Add (myParameter1);
- cmd3.Parameters.Add (myParameter2);
- cmd3.ExecuteNonQuery ();
- }
- static void OutParmTest1(OracleConnection con)
- {
- // test stored fuctions with 4 parameters
- // 1. input varchar2
- // 2. output varchar2
- // 3. input output varchar2
- // 4. return varchar2
- Console.WriteLine(" Create stored function SP_OUTPUTPARMTEST1 for testing VARCHAR2 Input, Output, InputOutput, Return parameters...");
-
- OracleCommand cmd2 = con.CreateCommand();
- cmd2.CommandText =
- "CREATE OR REPLACE FUNCTION SF_TESTOUTPARM1(parm1 IN VARCHAR2, parm2 OUT VARCHAR2, parm3 IN OUT VARCHAR2) RETURN VARCHAR2 " +
- "IS " +
- " returnValue VARCHAR2(32) := 'Anywhere';" +
- "BEGIN " +
- " IF parm1 IS NULL THEN " +
- " parm2 := 'parm1 is null'; " +
- " ELSE " +
- " parm2 := 'One' || parm1 || 'Three'; " +
- " END IF; " +
- " IF parm3 IS NOT NULL THEN " +
- " parm3 := parm2 || parm3 || 'Five'; " +
- " ELSE " +
- " parm3 := 'parm3 in was NULL'; " +
- " END IF; " +
- " IF parm1 IS NOT NULL THEN " +
- " IF parm1 = '999' THEN " +
- " parm2 := NULL; " +
- " parm3 := NULL; " +
- " returnValue := NULL; " +
- " END IF; " +
- " END IF; " +
- " RETURN returnValue; " +
- "END;";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" Call stored function SF_TESTOUTPARM1 with 4 parameters...");
- OracleCommand cmd3 = con.CreateCommand();
- cmd3.CommandType = CommandType.Text;
- cmd3.CommandText =
- "BEGIN " +
- " :ReturnValue := SF_TESTOUTPARM1(:p1, :p2, :p3); " +
- "END;";
- OracleParameter myParameter1 = new OracleParameter("p1", OracleType.VarChar);
- myParameter1.Value = "Two";
- myParameter1.Size = 32;
- myParameter1.Direction = ParameterDirection.Input;
- OracleParameter myParameter2 = new OracleParameter("p2", OracleType.VarChar);
- myParameter2.Size = 32;
- myParameter2.Direction = ParameterDirection.Output;
- OracleParameter myParameter3 = new OracleParameter("p3", OracleType.VarChar);
- myParameter3.Value = "Four";
- myParameter3.Size = 32;
- myParameter3.Direction = ParameterDirection.InputOutput;
- OracleParameter myParameter4 = new OracleParameter("ReturnValue", OracleType.VarChar);
- myParameter4.Size = 32;
- myParameter4.Direction = ParameterDirection.ReturnValue;
- cmd3.Parameters.Add(myParameter1);
- cmd3.Parameters.Add(myParameter2);
- cmd3.Parameters.Add(myParameter3);
- cmd3.Parameters.Add(myParameter4);
- cmd3.ExecuteNonQuery();
- string outValue = (string)myParameter2.Value;
- string inOutValue = (string)myParameter3.Value;
- string returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 1Out Value should be: OneTwoThree");
- Console.WriteLine(" 1Out Value: " + outValue);
- Console.WriteLine(" 1InOut Value should be: OneTwoThreeFourFive");
- Console.WriteLine(" 1InOut Value: " + inOutValue);
- Console.WriteLine(" 1Return Value should be: Anywhere");
- Console.WriteLine(" 1Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = DBNull.Value;
- myParameter3.Value = "Hello";
- cmd3.ExecuteNonQuery();
- outValue = (string)myParameter2.Value;
- inOutValue = (string)myParameter3.Value;
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 2Out Value should be: parm1 is null");
- Console.WriteLine(" 2Out Value: " + outValue);
- Console.WriteLine(" 2InOut Value should be: parm1 is nullHelloFive");
- Console.WriteLine(" 2InOut Value: " + inOutValue);
- Console.WriteLine(" 2Return Value should be: Anywhere");
- Console.WriteLine(" 2Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = "999";
- myParameter3.Value = "Bye";
- cmd3.ExecuteNonQuery();
- if (myParameter2.Value == DBNull.Value)
- outValue = "Value is DBNull.Value";
- else
- outValue = (string)myParameter2.Value;
- if( myParameter3.Value == DBNull.Value)
- inOutValue = "Value is DBNull.Value";
- else
- inOutValue = (string)myParameter3.Value;
- if (myParameter4.Value == DBNull.Value)
- returnValue = "Value is DBNull.Value";
- else
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 3Out Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3Out Value: " + outValue);
- Console.WriteLine(" 3InOut Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3InOut Value: " + inOutValue);
- Console.WriteLine(" 3Return Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = "***";
- myParameter3.Value = DBNull.Value;
- cmd3.ExecuteNonQuery();
- outValue = (string)myParameter2.Value;
- inOutValue = (string)myParameter3.Value;
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 4Out Value should be: One***Three");
- Console.WriteLine(" 4Out Value: " + outValue);
- Console.WriteLine(" 4InOut Value should be: parm3 in was NULL");
- Console.WriteLine(" 4InOut Value: " + inOutValue);
- Console.WriteLine(" 4Return Value should be: Anywhere");
- Console.WriteLine(" 4Return Value: " + returnValue);
- Console.WriteLine();
- }
- static void OutParmTest2 (OracleConnection con)
- {
- // test stored function with 4 parameters
- // 1. input number(18,2)
- // 2. output number(18,2)
- // 3. input output number (18,2)
- // 4. return number (18,2)
- Console.WriteLine(" Create stored function SF_TESTOUTPARM2 to test NUMBER parameters...");
- // stored procedure addes two numbers
- OracleCommand cmd2 = con.CreateCommand();
- cmd2.CommandText =
- "CREATE OR REPLACE FUNCTION SF_TESTOUTPARM2(parm1 IN NUMBER, parm2 OUT NUMBER, parm3 IN OUT NUMBER) RETURN NUMBER " +
- "IS " +
- " returnValue NUMBER := 123.45; " +
- "BEGIN " +
- " IF parm1 IS NULL THEN " +
- " parm2 := 18; " +
- " parm3 := parm3 + 8000; " +
- " returnValue := 78; " +
- " ELSIF parm1 = 999 THEN " +
- " parm2 := NULL;" +
- " parm3 := NULL;" +
- " returnValue := NULL;" +
- " ELSIF parm3 IS NULL THEN " +
- " parm2 := 0; " +
- " parm3 := 1234567890123.12345678; " +
- " ELSE " +
- " parm2 := parm1 + 3; " +
- " parm3 := parm3 + 70; " +
- " END IF;" +
- " RETURN returnValue;" +
- "END;";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" Call stored function SP_TESTOUTPARM2 with 4 parameters...");
- OracleCommand cmd3 = con.CreateCommand();
- cmd3.CommandType = CommandType.Text;
- cmd3.CommandText =
- "BEGIN " +
- " :returnValue := SF_TESTOUTPARM2(:p1, :p2, :p3);" +
- "END;";
- OracleParameter myParameter1 = new OracleParameter("p1", OracleType.Number);
- myParameter1.Value = 2.2;
- myParameter1.Direction = ParameterDirection.Input;
- OracleParameter myParameter2 = new OracleParameter("p2", OracleType.Number);
- myParameter2.Direction = ParameterDirection.Output;
- OracleParameter myParameter3 = new OracleParameter("p3", OracleType.Number);
- myParameter3.Value = 33.4;
- myParameter3.Direction = ParameterDirection.InputOutput;
- OracleParameter myParameter4 = new OracleParameter("returnValue", OracleType.Number);
- myParameter4.Direction = ParameterDirection.ReturnValue;
- cmd3.Parameters.Add(myParameter1);
- cmd3.Parameters.Add(myParameter2);
- cmd3.Parameters.Add(myParameter3);
- cmd3.Parameters.Add(myParameter4);
- cmd3.ExecuteNonQuery();
- decimal outValue = (decimal)myParameter2.Value;
- decimal inOutValue = (decimal)myParameter3.Value;
- decimal returnValue = (decimal)myParameter4.Value;
- Console.WriteLine(" 1Out Value should be: 5.20");
- Console.WriteLine(" 1Out Value: {0}", outValue);
- Console.WriteLine(" 1InOut Value should be: 103.40");
- Console.WriteLine(" 1InOut Value: {0}", inOutValue);
- Console.WriteLine(" 1Return Value should be: 123.45");
- Console.WriteLine(" 1Return Value: {0}", returnValue);
- Console.WriteLine();
- myParameter1.Value = DBNull.Value;
- myParameter3.Value = 23;
- cmd3.ExecuteNonQuery();
- outValue = (decimal)myParameter2.Value;
- inOutValue = (decimal)myParameter3.Value;
- returnValue = (decimal)myParameter4.Value;
- Console.WriteLine(" 2Out Value should be: 18");
- Console.WriteLine(" 2Out Value: {0}", outValue);
- Console.WriteLine(" 2InOut Value should be: 8023");
- Console.WriteLine(" 2InOut Value: {0}", inOutValue);
- Console.WriteLine(" 2Return Value should be: 78");
- Console.WriteLine(" 2Return Value: {0}", returnValue);
- Console.WriteLine();
- string soutValue = "";
- string sinOutValue = "";
- string sreturnValue = "";
- myParameter1.Value = 999;
- myParameter3.Value = 66;
- cmd3.ExecuteNonQuery();
- if (myParameter2.Value == DBNull.Value)
- soutValue = "DBNull.Value";
- else
- soutValue = myParameter2.Value.ToString();
- if (myParameter3.Value == DBNull.Value)
- sinOutValue = "DBNull.Value";
- else
- sinOutValue = myParameter3.Value.ToString();
- if (myParameter4.Value == DBNull.Value)
- sreturnValue = "DBNull.Value";
- else
- sreturnValue = myParameter4.Value.ToString();
- Console.WriteLine(" 3Out Value should be: DBNull.Value");
- Console.WriteLine(" 3Out Value: {0}", soutValue);
- Console.WriteLine(" 3InOut Value should be: DBNull.Value");
- Console.WriteLine(" 3InOut Value: {0}", sinOutValue);
- Console.WriteLine(" 3Return Value should be: DBNull.Value");
- Console.WriteLine(" 3Return Value: {0}", sreturnValue);
- Console.WriteLine();
- myParameter1.Value = 111;
- myParameter3.Value = DBNull.Value;
- cmd3.ExecuteNonQuery();
- outValue = (decimal)myParameter2.Value;
- inOutValue = (decimal)myParameter3.Value;
- returnValue = (decimal)myParameter4.Value;
- Console.WriteLine(" 4Out Value should be: 0 (as in digit zero)");
- Console.WriteLine(" 4Out Value: {0}", outValue);
- Console.WriteLine(" 4InOut Value should be: 1234567890123.12345678");
- Console.WriteLine(" 4InOut Value: {0}", inOutValue);
- Console.WriteLine(" 4Return Value should be: 123.45");
- Console.WriteLine(" 4Return Value: {0}", returnValue);
- Console.WriteLine();
- }
- static void OutParmTest3 (OracleConnection con)
- {
- // test stored function with 4 parameters
- // 1. input date
- // 2. output date
- // 3. input output date
- // 4. return dae
- // a DATE type in Oracle has Date and Time
- Console.WriteLine(" Create stored function SF_TESTOUTPARM3 to test Date parameters...");
- OracleCommand cmd2 = con.CreateCommand();
- cmd2.CommandText =
- "CREATE OR REPLACE FUNCTION SF_TESTOUTPARM3(parm1 IN DATE, parm2 OUT DATE, parm3 IN OUT DATE) RETURN DATE " +
- "IS " +
- " returnValue DATE := TO_DATE('2001-07-01 15:32:52', 'YYYY-MM-DD HH24:MI:SS');" +
- "BEGIN " +
- " IF parm1 IS NULL THEN " +
- " parm2 := TO_DATE('1900-12-31', 'YYYY-MM-DD'); " +
- " parm3 := TO_DATE('1900-12-31', 'YYYY-MM-DD'); " +
- " ELSIF parm1 = TO_DATE('1979-11-25','YYYY-MM-DD') THEN " +
- " parm2 := NULL;" +
- " parm3 := NULL;" +
- " returnValue := NULL;"+
- " ELSIF parm3 IS NULL THEN " +
- " parm2 := TO_DATE('2008-08-08', 'YYYY-MM-DD');" +
- " parm3 := TO_DATE('2000-01-01', 'YYYY-MM-DD');" +
- " ELSE " +
- " -- add 3 days to date\n " +
- " parm2 := parm1 + 3; " +
- " parm3 := parm3 + 5; " +
- " END IF; " +
- " RETURN returnValue;" +
- "END;";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" Call stored function SF_TESTOUTPARM3 with 4 parameters...");
- OracleCommand cmd3 = con.CreateCommand();
- cmd3.CommandType = CommandType.Text;
- cmd3.CommandText =
- "BEGIN " +
- " :returnValue := SF_TESTOUTPARM3(:p1, :p2, :p3);" +
- "END;";
- OracleParameter myParameter1 = new OracleParameter("p1", OracleType.DateTime);
- myParameter1.Value = new DateTime(2004, 12, 15);
- myParameter1.Direction = ParameterDirection.Input;
- OracleParameter myParameter2 = new OracleParameter("p2", OracleType.DateTime);
- myParameter2.Direction = ParameterDirection.Output;
- OracleParameter myParameter3 = new OracleParameter("p3", OracleType.DateTime);
- myParameter3.Value = new DateTime(2008, 10, 14, 20, 21, 22);
- myParameter3.Direction = ParameterDirection.InputOutput;
- OracleParameter myParameter4 = new OracleParameter("returnValue", OracleType.DateTime);
- myParameter4.Direction = ParameterDirection.ReturnValue;
- cmd3.Parameters.Add(myParameter1);
- cmd3.Parameters.Add(myParameter2);
- cmd3.Parameters.Add(myParameter3);
- cmd3.Parameters.Add(myParameter4);
- cmd3.ExecuteNonQuery();
- DateTime outValue = (DateTime)myParameter2.Value;
- DateTime inOutValue = (DateTime)myParameter3.Value;
- DateTime returnValue = (DateTime)myParameter4.Value;
- Console.WriteLine(" 1Out Value should be: 2004-12-18 00:00:00");
- Console.WriteLine(" 1Out Value: {0}", outValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 1InOut Value should be: 2008-10-19 20:21:22");
- Console.WriteLine(" 1InOut Value: {0}", inOutValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 1Return Value should be: 2001-07-01 15:32:52");
- Console.WriteLine(" 1Return Value: {0}", returnValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine();
- myParameter1.Value = DBNull.Value;
- myParameter3.Value = new DateTime(1980, 11, 22);
- cmd3.ExecuteNonQuery();
- outValue = (DateTime)myParameter2.Value;
- inOutValue = (DateTime)myParameter3.Value;
- returnValue = (DateTime)myParameter4.Value;
- Console.WriteLine(" 2Out Value should be: 1900-12-31 00:00:00");
- Console.WriteLine(" 2Out Value: {0}", outValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 2InOut Value should be: 1900-12-31 00:00:00");
- Console.WriteLine(" 2InOut Value: {0}", inOutValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 2Return Value should be: 2001-07-01 15:32:52");
- Console.WriteLine(" 2Return Value: {0}", returnValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine();
- myParameter1.Value = new DateTime(1979, 11, 25);
- myParameter3.Value = new DateTime(1981, 12, 14);
- cmd3.ExecuteNonQuery();
- string soutValue = "";
- string sinOutValue = "";
- string sreturnValue = "";
- if (myParameter2.Value == DBNull.Value)
- soutValue = "DBNull.Value";
- else {
- outValue = (DateTime)myParameter2.Value;
- soutValue = outValue.ToString("yyyy-MM-dd HH:mm:ss");
- }
- if (myParameter3.Value == DBNull.Value)
- sinOutValue = "DBNull.Value";
- else {
- inOutValue = (DateTime)myParameter3.Value;
- sinOutValue = inOutValue.ToString("yyyy-MM-dd HH:mm:ss");
- }
- if (myParameter4.Value == DBNull.Value)
- sreturnValue = "DBNull.Value";
- else {
- returnValue = (DateTime)myParameter4.Value;
- sreturnValue = returnValue.ToString("yyyy-MM-dd HH:mm:ss");
- }
- Console.WriteLine(" 3Out Value should be: DBNull.Value");
- Console.WriteLine(" 3Out Value: {0}", soutValue);
- Console.WriteLine(" 3InOut Value should be: DBNull.Value");
- Console.WriteLine(" 3InOut Value: {0}", sinOutValue);
- Console.WriteLine(" 3Return Value should be: DBNull.Value");
- Console.WriteLine(" 3Return Value: {0}", sreturnValue);
- Console.WriteLine();
- myParameter1.Value = new DateTime(1976, 7, 4);
- myParameter3.Value = DBNull.Value;
- cmd3.ExecuteNonQuery();
- outValue = (DateTime)myParameter2.Value;
- inOutValue = (DateTime)myParameter3.Value;
- returnValue = (DateTime)myParameter4.Value;
- Console.WriteLine(" 4Out Value should be: 2008-08-08 00:00:00");
- Console.WriteLine(" 4Out Value: {0}", outValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 4InOut Value should be: 2000-01-01 00:00:00");
- Console.WriteLine(" 4InOut Value: {0}", inOutValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine(" 4Return Value should be: 2001-07-01 15:32:52");
- Console.WriteLine(" 4Return Value: {0}", returnValue.ToString("yyyy-MM-dd HH:mm:ss"));
- Console.WriteLine();
- }
- static void OutParmTest4(OracleConnection con)
- {
- // test stored fuctions with 4 parameters
- // 1. input long
- // 2. output long
- // 3. input output long
- // 4. return long
- Console.WriteLine(" Create stored function SP_OUTPUTPARMTEST4 for testing LONG VARCHAR Input, Output, InputOutput, Return parameters...");
- OracleCommand cmd2 = con.CreateCommand();
- cmd2.CommandText =
- "CREATE OR REPLACE FUNCTION SP_OUTPUTPARMTEST4(parm1 IN LONG, parm2 OUT LONG, parm3 IN OUT LONG) RETURN LONG " +
- "IS " +
- " returnValue LONG := 'A very, very, very long value in a far away memory space.'; " +
- "BEGIN " +
- " IF parm1 IS NULL THEN " +
- " parm2 := 'parm1 is null'; " +
- " returnValue := 'Another one bytes the dust.'; " +
- " ELSE " +
- " parm2 := 'One' || parm1 || 'Three'; " +
- " END IF; " +
- " IF parm3 IS NOT NULL THEN " +
- " parm3 := parm2 || parm3 || 'Five'; " +
- " ELSE " +
- " parm3 := 'parm3 in was NULL'; " +
- " END IF; " +
- " IF parm1 IS NOT NULL THEN " +
- " IF parm1 = '999' THEN " +
- " parm2 := NULL; " +
- " parm3 := NULL; " +
- " returnValue := NULL; " +
- " END IF; " +
- " END IF; " +
- " RETURN returnValue; " +
- "END;";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" COMMIT...");
- cmd2.CommandText = "COMMIT";
- cmd2.ExecuteNonQuery();
- Console.WriteLine(" Call stored procedure SP_OUTPUTPARMTEST4 with 4 parameters...");
- OracleCommand cmd3 = con.CreateCommand();
- cmd3.CommandType = CommandType.Text;
- cmd3.CommandText =
- "BEGIN " +
- " :ReturnValue := SP_OUTPUTPARMTEST4(:p1, :p2, :p3); " +
- "END;";
- OracleParameter myParameter1 = new OracleParameter("p1", OracleType.LongVarChar);
- myParameter1.Size = 1000;
- myParameter1.Direction = ParameterDirection.Input;
- myParameter1.Value = "Two";
- OracleParameter myParameter2 = new OracleParameter("p2", OracleType.LongVarChar);
- myParameter2.Size = 1000;
- myParameter2.Direction = ParameterDirection.Output;
- OracleParameter myParameter3 = new OracleParameter("p3", OracleType.LongVarChar);
- myParameter3.Value = "Four";
- myParameter3.Size = 1000;
- myParameter3.Direction = ParameterDirection.InputOutput;
- OracleParameter myParameter4 = new OracleParameter("ReturnValue", OracleType.LongVarChar);
- myParameter4.Size = 1000;
- myParameter4.Direction = ParameterDirection.ReturnValue;
- cmd3.Parameters.Add(myParameter1);
- cmd3.Parameters.Add(myParameter2);
- cmd3.Parameters.Add(myParameter3);
- cmd3.Parameters.Add(myParameter4);
- cmd3.ExecuteNonQuery();
- string outValue = (string)myParameter2.Value;
- string inOutValue = (string)myParameter3.Value;
- string returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 1Out Value should be: OneTwoThree");
- Console.WriteLine(" 1Out Value: " + outValue);
- Console.WriteLine(" 1InOut Value should be: OneTwoThreeFourFive");
- Console.WriteLine(" 1InOut Value: " + inOutValue);
- Console.WriteLine(" 1Return Value should be: A very, very, very long value in a far away memory space.");
- Console.WriteLine(" 1Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = DBNull.Value;
- myParameter3.Value = "Hello";
- cmd3.ExecuteNonQuery();
- outValue = (string)myParameter2.Value;
- inOutValue = (string)myParameter3.Value;
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 2Out Value should be: parm1 is null");
- Console.WriteLine(" 2Out Value: " + outValue);
- Console.WriteLine(" 2InOut Value should be: parm1 is nullHelloFive");
- Console.WriteLine(" 2InOut Value: " + inOutValue);
- Console.WriteLine(" 2Return Value should be: Another one bytes the dust.");
- Console.WriteLine(" 2Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = "999";
- myParameter3.Value = "Bye";
- cmd3.ExecuteNonQuery();
- if (myParameter2.Value == DBNull.Value)
- outValue = "Value is DBNull.Value";
- else
- outValue = (string)myParameter2.Value;
- if (myParameter3.Value == DBNull.Value)
- inOutValue = "Value is DBNullValue";
- else
- inOutValue = (string)myParameter3.Value;
- if (myParameter4.Value == DBNull.Value)
- returnValue = "Value is DBNull.Value";
- else
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 3Out Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3Out Value: " + outValue);
- Console.WriteLine(" 3InOut Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3InOut Value: " + inOutValue);
- Console.WriteLine(" 3Return Value should be: Value is DBNull.Value");
- Console.WriteLine(" 3Return Value: " + returnValue);
- Console.WriteLine();
- myParameter1.Value = "***";
- myParameter3.Value = DBNull.Value;
- cmd3.ExecuteNonQuery();
- outValue = (string)myParameter2.Value;
- inOutValue = (string)myParameter3.Value;
- returnValue = (string)myParameter4.Value;
- Console.WriteLine(" 4Out Value should be: One***Three");
- Console.WriteLine(" 4Out Value: " + outValue);
- Console.WriteLine(" 4InOut Value should be: parm3 in was NULL");
- Console.WriteLine(" 4InOut Value: " + inOutValue);
- Console.WriteLine(" 4Return Value should be: A very, very, very long value in a far away memory space.");
- Console.WriteLine(" 4Return Value: " + returnValue);
- Console.WriteLine();
- }
- static void ShowConnectionProperties (OracleConnection con)
- {
- try {
- Console.WriteLine ("ServerVersion: " + con.ServerVersion);
- } catch (System.InvalidOperationException ioe) {
- Console.WriteLine ("InvalidOperationException caught.");
- Console.WriteLine ("Message: " + ioe.Message);
- }
- Console.WriteLine ("DataSource: " + con.DataSource);
- }
- static void NullAggregateTest (OracleConnection con)
- {
- Console.WriteLine(" Drop table MONO_TEST_TABLE3...");
- OracleCommand cmd2 = con.CreateCommand ();
- try {
- cmd2.CommandText = "DROP TABLE MONO_TEST_TABLE3";
- cmd2.ExecuteNonQuery ();
- }
- catch(OracleException) {
- // ignore if table already exists
- }
- Console.WriteLine(" Create table MONO_TEST_TABLE3...");
-
- cmd2.CommandText = "CREATE TABLE MONO_TEST_TABLE3 (" +
- " COL1 VARCHAR2(8), "+
- " COL2 VARCHAR2(32))";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" Insert some rows into table MONO_TEST_TABLE3...");
- cmd2.CommandText = "INSERT INTO MONO_TEST_TABLE3 (COL1, COL2) VALUES ('1','one')";
- cmd2.ExecuteNonQuery ();
- cmd2.CommandText = "INSERT INTO MONO_TEST_TABLE3 (COL1, COL2) VALUES ('1','uno')";
- cmd2.ExecuteNonQuery ();
-
- cmd2.CommandText = "INSERT INTO MONO_TEST_TABLE3 (COL1, COL2) VALUES ('3','three')";
- cmd2.ExecuteNonQuery ();
-
- cmd2.CommandText = "INSERT INTO MONO_TEST_TABLE3 (COL1, COL2) VALUES ('3', null)";
- cmd2.ExecuteNonQuery ();
- cmd2.CommandText = "INSERT INTO MONO_TEST_TABLE3 (COL1, COL2) VALUES ('3','few')";
- cmd2.ExecuteNonQuery ();
- Console.WriteLine(" ExecuteScalar...");
- cmd2.CommandText = "SELECT COL1, COUNT(COL2) AS MAX_COL1 FROM MONO_TEST_TABLE3 GROUP BY COL1";
- OracleDataReader reader = cmd2.ExecuteReader ();
- Console.WriteLine (" Read...");
- while (reader.Read ()) {
- object obj0 = reader.GetValue (0);
- Console.WriteLine("Value 0: " + obj0.ToString ());
- object obj1 = reader.GetValue (1);
- Console.WriteLine("Value 1: " + obj1.ToString ());
-
- Console.WriteLine (" Read...");
- }
- Console.WriteLine (" No more records.");
- }
- static void OnInfoMessage (object sender, OracleInfoMessageEventArgs e)
- {
- Console.WriteLine("InfoMessage Message: " + e.Message.ToString());
- Console.WriteLine("InfoMessage Code: " + e.Code.ToString());
- Console.WriteLine("InfoMessage Source: " + e.Source.ToString());
- }
- static void OnStateChange (object sender, StateChangeEventArgs e)
- {
- Console.WriteLine("StateChange CurrentSate:" + e.CurrentState.ToString ());
- Console.WriteLine("StateChange OriginalState:" + e.OriginalState.ToString ());
- }
- static void RefCursorTests(OracleConnection con)
- {
- SetupRefCursorTests(con); // for ref cursor tests 1 thru 3
- RefCursorTest1(con); // using BEGIN/END
- RefCursorTest2(con); // using call
- RefCursorTest3(con); // using CommandType.StoredProcedure
-
- RefCursorTest4(con);
- }
- static void SetupRefCursorTests(OracleConnection con)
- {
- Console.WriteLine("Setup Oracle package curspkg_join...");
-
- OracleCommand cmd = con.CreateCommand();
- Console.Error.WriteLine(" create or replace package curspkg_join...");
- cmd.CommandText =
- "CREATE OR REPLACE PACKAGE curspkg_join AS\n" +
- "TYPE t_cursor IS REF CURSOR;\n" +
- "Procedure open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor);\n" +
- "END curspkg_join;";
- cmd.ExecuteNonQuery();
- Console.Error.WriteLine(" create or replace package body curspkg_join...");
- cmd.CommandText =
- "CREATE OR REPLACE PACKAGE BODY curspkg_join AS\n" +
- " Procedure open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor)\n" +
- " IS\n" +
- " v_cursor t_cursor;\n" +
- " BEGIN\n" +
- " IF n_EMPNO <> 0 THEN\n" +
- " OPEN v_cursor FOR\n" +
- " SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME\n" +
- " FROM SCOTT.EMP, SCOTT.DEPT\n" +
- " WHERE EMP.DEPTNO = DEPT.DEPTNO\n" +
- " AND EMP.EMPNO = n_EMPNO;\n" +
- "\n" +
- " ELSE\n" +
- " OPEN v_cursor FOR\n" +
- " SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME\n" +
- " FROM SCOTT.EMP, SCOTT.DEPT\n" +
- " WHERE EMP.DEPTNO = DEPT.DEPTNO;\n" +
- "\n" +
- " END IF;\n" +
- " io_cursor := v_cursor;\n" +
- " END open_join_cursor1;\n" +
- "END curspkg_join;";
- cmd.ExecuteNonQuery();
- cmd.CommandText = "commit";
- cmd.ExecuteNonQuery();
- }
- public static void RefCursorTest4(OracleConnection connection)
- {
- Console.WriteLine("Setup test package and data for RefCursorTest4...");
- OracleCommand cmddrop = connection.CreateCommand();
- cmddrop.CommandText = "DROP TABLE TESTTABLE";
- try {
- cmddrop.ExecuteNonQuery();
- }
- catch(OracleException e) {
- Console.WriteLine("Ignore this error: " + e.Message);
- }
- cmddrop.Dispose();
- cmddrop = null;
- OracleCommand cmd = connection.CreateCommand();
- // create table TESTTABLE
- cmd.CommandText =
- "create table TESTTABLE (\n" +
- " col1 numeric(18,0),\n" +
- " col2 char(32),\n" +
- " col3 date)";
- cmd.ExecuteNonQuery();
- // insert some rows into TESTTABLE
- cmd.CommandText =
- "insert into TESTTABLE\n" +
- "(col1, col2, col3)\n" +
- "values(45, 'Mono', sysdate)";
- cmd.ExecuteNonQuery();
- cmd.CommandText =
- "insert into TESTTABLE\n" +
- "(col1, col2, col3)\n" +
- "values(136, 'Fun', sysdate)";
- cmd.ExecuteNonQuery();
- cmd.CommandText =
- "insert into TESTTABLE\n" +
- "(col1, col2, col3)\n" +
- "values(526, 'System.Data.OracleClient', sysdate)";
- cmd.ExecuteNonQuery();
- cmd.CommandText = "commit";
- cmd.ExecuteNonQuery();
- // create Oracle package TestTablePkg
- cmd.CommandText =
- "CREATE OR REPLACE PACKAGE TestTablePkg\n" +
- "AS\n" +
- " TYPE T_CURSOR IS REF CURSOR;\n" +
- "\n" +
- " PROCEDURE GetData(tableCursor OUT T_CURSOR);\n" +
- "END TestTablePkg;";
- cmd.ExecuteNonQuery();
- // create Oracle package body for package TestTablePkg
- cmd.CommandText =
- "CREATE OR REPLACE PACKAGE BODY TestTablePkg AS\n" +
- " PROCEDURE GetData(tableCursor OUT T_CURSOR)\n" +
- " IS\n" +
- " BEGIN\n" +
- " OPEN tableCursor FOR\n" +
- " SELECT *\n" +
- " FROM TestTable;\n" +
- " END GetData;\n" +
- "END TestTablePkg;";
- cmd.ExecuteNonQuery();
- cmd.Dispose();
- cmd = null;
- Console.WriteLine("Set up command and parameters to call stored proc...");
- OracleCommand command = new OracleCommand("TestTablePkg.GetData", connection);
- command.CommandType = CommandType.StoredProcedure;
- OracleParameter parameter = new OracleParameter("tableCursor", OracleType.Cursor);
- parameter.Direction = ParameterDirection.Output;
- command.Parameters.Add(parameter);
- Console.WriteLine("Execute...");
- command.ExecuteNonQuery();
- Console.WriteLine("Get OracleDataReader for cursor output parameter...");
- OracleDataReader reader = (OracleDataReader) parameter.Value;
-
- Console.WriteLine("Read data...");
- int r = 0;
- while (reader.Read()) {
- Console.WriteLine("Row {0}", r);
- for (int f = 0; f < reader.FieldCount; f ++) {
- object val = reader.GetValue(f);
- Console.WriteLine(" Field {0} Value: {1}", f, val.ToString());
- }
- r ++;
- }
- Console.WriteLine("Rows retrieved: {0}", r);
- Console.WriteLine("Clean up...");
- reader.Close();
- reader = null;
- command.Dispose();
- command = null;
- }
- static void RefCursorTest1(OracleConnection con)
- {
- Console.WriteLine("Ref Cursor Test 1 - using BEGIN/END for proc - Begin...");
- Console.WriteLine("Create command...");
- OracleCommand cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.CommandText =
- "BEGIN\n" +
- " curspkg_join.open_join_cursor1(:n_Empno,:io_cursor);\n" +
- "END;";
-
- // PL/SQL definition of stored procedure in package curspkg_join
- // open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor)
- Console.WriteLine("Create parameters...");
- OracleParameter parm1 = new OracleParameter("n_Empno", OracleType.Number);
- parm1.Direction = ParameterDirection.Input;
- parm1.Value = 7902;
- OracleParameter parm2 = new OracleParameter("io_cursor", OracleType.Cursor);
- parm2.Direction = ParameterDirection.Output;
- cmd.Parameters.Add(parm1);
- cmd.Parameters.Add(parm2);
- // positional parm
- //cmd.Parameters.Add(new OracleParameter("io_cursor", OracleType.Cursor)).Direction = ParameterDirection.Output;
- // named parm
- //cmd.Parameters.Add("n_Empno", OracleType.Number, 4).Value = 7902;
- OracleDataReader reader;
- Console.WriteLine("Execute Non Query...");
- cmd.ExecuteNonQuery();
- Console.WriteLine("Get data reader (ref cursor) from out parameter...");
- reader = (OracleDataReader) cmd.Parameters["io_cursor"].Value;
- int x, count;
- count = 0;
- Console.WriteLine("Get data from ref cursor...");
- while (reader.Read()) {
- for (x = 0; x < reader.FieldCount; x++)
- Console.Write(reader[x] + " ");
-
- Console.WriteLine();
- count += 1;
- }
- Console.WriteLine(count.ToString() + " Rows Returned.");
- reader.Close();
- }
- static void RefCursorTest2(OracleConnection con)
- {
- Console.WriteLine("Ref Cursor Test 2 - using call - Begin...");
- Console.WriteLine("Create command...");
- OracleCommand cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.CommandText = "call curspkg_join.open_join_cursor1(:n_Empno,:io_cursor)";
-
- // PL/SQL definition of stored procedure in package curspkg_join
- // open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor)
- Console.WriteLine("Create parameters...");
- OracleParameter parm1 = new OracleParameter("n_Empno", OracleType.Number);
- parm1.Direction = ParameterDirection.Input;
- parm1.Value = 7902;
- OracleParameter parm2 = new OracleParameter("io_cursor", OracleType.Cursor);
- parm2.Direction = ParameterDirection.Output;
- cmd.Parameters.Add(parm1);
- cmd.Parameters.Add(parm2);
- // positional parm
- //cmd.Parameters.Add(new OracleParameter("io_cursor", OracleType.Cursor)).Direction = ParameterDirection.Output;
- // named parm
- //cmd.Parameters.Add("n_Empno", OracleType.Number, 4).Value = 7902;
- OracleDataReader reader;
- Console.WriteLine("Execute Non Query...");
- cmd.ExecuteNonQuery();
- Console.WriteLine("Get data reader (ref cursor) from out parameter...");
- reader = (OracleDataReader) cmd.Parameters["io_cursor"].Value;
- int x, count;
- count = 0;
- Console.WriteLine("Get data from ref cursor...");
- while (reader.Read()) {
- for (x = 0; x < reader.FieldCount; x++)
- Console.Write(reader[x] + " ");
-
- Console.WriteLine();
- count += 1;
- }
- Console.WriteLine(count.ToString() + " Rows Returned.");
- reader.Close();
- }
- static void RefCursorTest3(OracleConnection con)
- {
- Console.WriteLine("Ref Cursor Test 3 - CommandType.StoredProcedure - Begin...");
- Console.WriteLine("Create command...");
- OracleCommand cmd = new OracleCommand();
- cmd.Connection = con;
- cmd.CommandText = "curspkg_join.open_join_cursor1";
- cmd.CommandType = CommandType.StoredProcedure;
-
- // PL/SQL definition of stored procedure in package curspkg_join
- // open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor)
- Console.WriteLine("Create parameters...");
- OracleParameter parm1 = new OracleParameter("n_Empno", OracleType.Number);
- parm1.Direction = ParameterDirection.Input;
- parm1.Value = 7902;
- OracleParameter parm2 = new OracleParameter("io_cursor", OracleType.Cursor);
- parm2.Direction = ParameterDirection.Output;
- cmd.Parameters.Add(parm1);
- cmd.Parameters.Add(parm2);
- // positional parm
- //cmd.Parameters.Add(new OracleParameter("io_cursor", OracleType.Cursor)).Direction = ParameterDirection.Output;
- // named parm
- //cmd.Parameters.Add("n_Empno", OracleType.Number, 4).Value = 7902;
- OracleDataReader reader;
- Console.WriteLine("Execute Non Query...");
- cmd.ExecuteNonQuery();
- Console.WriteLine("Get data reader (ref cursor) from out parameter...");
- reader = (OracleDataReader) cmd.Parameters["io_cursor"].Value;
- int x, count;
- count = 0;
- Console.WriteLine("Get data from ref cursor...");
- while (reader.Read()) {
- for (x = 0; x < reader.FieldCount; x++)
- Console.Write(reader[x] + " ");
-
- Console.WriteLine();
- count += 1;
- }
- Console.WriteLine(count.ToString() + " Rows Returned.");
- reader.Close();
- }
- static void ExternalAuthenticationTest ()
- {
- string user = Environment.UserName;
- if (!Environment.UserDomainName.Equals(String.Empty))
- user = Environment.UserDomainName + "\\" + Environment.UserName;
- Console.WriteLine("Environment UserDomainName and UserName: " + user);
- Console.WriteLine("Open connection using external authentication...");
- OracleConnection con = new OracleConnection("Data Source=palis;Integrated Security=true");
- try {
- con.Open();
- OracleCommand cmd = con.CreateCommand();
- cmd.CommandText = "SELECT USER FROM DUAL";
- OracleDataReader reader = cmd.ExecuteReader();
- if (reader.Read())
- Console.WriteLine("User: " + reader.GetString(reader.GetOrdinal("USER")));
- con.Close();
- }
- catch (Exception e) {
- Console.WriteLine("Exception caught: " + e.Message);
- Console.WriteLine("Probably not setup for external authentication.");
- }
- con.Dispose();
- con = null;
- }
- public static void TestPersistSucurityInfo1()
- {
- Console.WriteLine("\nTestPersistSucurityInfo1 - persist security info=false");
- OracleConnection con = new OracleConnection("data source=palis;user id=scott;password=tiger;persist security info=false");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- con.Open();
- Console.WriteLine("ConnectionString after open: " + con.ConnectionString);
- con.Close();
- Console.WriteLine("ConnectionString after close: " + con.ConnectionString);
- con = null;
- }
- public static void TestPersistSucurityInfo2()
- {
- Console.WriteLine("\nTestPersistSucurityInfo2 - persist security info=true");
- OracleConnection con = new OracleConnection("data source=palis;user id=scott;password=tiger;persist security info=true");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- con.Open();
- Console.WriteLine("ConnectionString after open: " + con.ConnectionString);
- con.Close();
- Console.WriteLine("ConnectionString after close: " + con.ConnectionString);
- con = null;
- }
- public static void TestPersistSucurityInfo3()
- {
- Console.WriteLine("\nTestPersistSucurityInfo3 - use default for persist security info which is false");
- OracleConnection con = new OracleConnection("data source=palis;user id=scott;password=tiger");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- con.Open();
- Console.WriteLine("ConnectionString after open: " + con.ConnectionString);
- con.Close();
- Console.WriteLine("ConnectionString after close: " + con.ConnectionString);
- con = null;
- }
- public static void TestPersistSucurityInfo4()
- {
- Console.WriteLine("\nTestPersistSucurityInfo4 - persist security info=false with password at front");
- OracleConnection con = new OracleConnection(";password=tiger;data source=palis;user id=scott;persist security info=false");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- con.Open();
- Console.WriteLine("ConnectionString after open: " + con.ConnectionString);
- con.Close();
- Console.WriteLine("ConnectionString after close: " + con.ConnectionString);
- con = null;
- }
- public static void TestPersistSucurityInfo5()
- {
- Console.WriteLine("\nTestPersistSucurityInfo5 - persist security info=false");
- OracleConnection con = new OracleConnection("data source=palis;user id=scott;password=tiger;persist security info=false");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- con.Open();
- Console.WriteLine("ConnectionString after open: " + con.ConnectionString);
- Console.WriteLine("ConnectionState for con: " + con.State.ToString() + "\n");
-
- Console.WriteLine("Clone OracleConnection...");
- OracleConnection con2 = (OracleConnection) ((ICloneable) con).Clone();
-
- Console.WriteLine("ConnectionState for con2: " + con2.State.ToString());
- Console.WriteLine("con2 ConnectionString before open: " + con2.ConnectionString);
- con2.Open();
- Console.WriteLine("con2 ConnectionString after open: " + con2.ConnectionString);
- con2.Close();
- Console.WriteLine("con2 ConnectionString after close: " + con2.ConnectionString);
-
- con.Close();
- }
- public static void TestPersistSucurityInfo6()
- {
- Console.WriteLine("\nTestPersistSucurityInfo6 - external auth using persist security info");
- string user = Environment.UserName;
- if (!Environment.UserDomainName.Equals(String.Empty))
- user = Environment.UserDomainName + "\\" + Environment.UserName;
- Console.WriteLine("Environment UserDomainName and UserName: " + user);
- Console.WriteLine("Open connection using external authentication...");
- OracleConnection con = new OracleConnection("Data Source=palis;Integrated Security=true");
- Console.WriteLine("ConnectionString before open: " + con.ConnectionString);
- try {
- con.Open();
- OracleCommand cmd = con.CreateCommand();
- cmd.CommandText = "SELECT USER FROM DUAL";
- OracleDataReader reader = cmd.ExecuteReader();
- if (reader.Read())
- Console.WriteLine("User: " + reader.GetString(reader.GetOrdinal("USER")));
- con.Close();
- Console.WriteLine("ConnectionString after close: " + con.ConnectionString);
- }
- catch (Exception e) {
- Console.WriteLine("Exception caught: " + e.Message);
- Console.WriteLine("Probably not setup for external authentication. This is fine.");
- }
- con.Dispose();
- Console.WriteLine("ConnectionString after dispose: " + con.ConnectionString);
- con = null;
- Console.WriteLine("\n\n");
- }
- public static void ConnectionPoolingTest1 ()
- {
- Console.WriteLine("Start Connection Pooling Test 1...");
- OracleConnection[] connections = null;
- int maxCon = MAX_CONNECTIONS + 1; // add 1 more over the max connections to cause it to wait for the next available connection
- int i = 0;
- try {
- connections = new OracleConnection[maxCon];
-
- for (i = 0; i < maxCon; i++) {
- Console.WriteLine(" Open connection: {0}", i);
- connections[i] = new OracleConnection(conStr);
- connections[i].Open ();
- }
- } catch (InvalidOperationException e) {
- Console.WriteLine("Expected exception InvalidOperationException caught.");
- Console.WriteLine(e);
- }
- for (i = 0; i < maxCon; i++) {
- if (connections[i] != null) {
- Console.WriteLine(" Close connection: {0}", i);
- if (connections[i].State == ConnectionState.Open)
- connections[i].Close ();
- connections[i].Dispose ();
- connections[i] = null;
- }
- }
- connections = null;
- Console.WriteLine("Done Connection Pooling Test 1.");
- }
- public static void ConnectionPoolingTest2 ()
- {
- Console.WriteLine("Start Connection Pooling Test 2...");
- OracleConnection[] connections = null;
- int maxCon = MAX_CONNECTIONS;
- int i = 0;
- connections = new OracleConnection[maxCon];
-
- for (i = 0; i < maxCon; i++) {
- Console.WriteLine(" Open connection: {0}", i);
- connections[i] = new OracleConnection(conStr);
- connections[i].Open ();
- }
-
- Console.WriteLine("Start another thread...");
- t = new Thread(new ThreadStart(AnotherThreadProc));
- t.Start ();
- Console.WriteLine("Sleep...");
- Thread.Sleep(100);
- Console.WriteLine("Closing...");
- for (i = 0; i < maxCon; i++) {
- if (connections[i] != null) {
- Console.WriteLine(" Close connection: {0}", i);
- if (connections[i].State == ConnectionState.Open)
- connections[i].Close ();
- connections[i].Dispose ();
- connections[i] = null;
- }
- }
- connections = null;
- }
- private static void AnotherThreadProc ()
- {
- Console.WriteLine("Open connection via another thread...");
- OracleConnection[] connections = null;
- int maxCon = MAX_CONNECTIONS;
- int i = 0;
- connections = new OracleConnection[maxCon];
-
- for (i = 0; i < maxCon; i++) {
- Console.WriteLine(" Open connection: {0}", i);
- connections[i] = new OracleConnection(conStr);
- connections[i].Open ();
- }
- Console.WriteLine("Done Connection Pooling Test 2.");
- System.Environment.Exit (0);
- }
- [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]);
- conStr = connectionString;
- OracleConnection con1 = new OracleConnection();
- ShowConnectionProperties (con1);
- con1.ConnectionString = connectionString;
- con1.InfoMessage += new OracleInfoMessageEventHandler (OnInfoMessage);
- con1.StateChange += new StateChangeEventHandler (OnStateChange);
- Console.WriteLine("Opening...");
- con1.Open ();
- Console.WriteLine("Opened.");
- ShowConnectionProperties (con1);
- Console.WriteLine ("Mono Oracle Test BEGIN ...");
- MonoTest (con1);
- Console.WriteLine ("Mono Oracle Test END ...");
- Wait ("");
-
- Console.WriteLine ("LOB Test BEGIN...");
- CLOBTest (con1);
- BLOBTest (con1);
- Console.WriteLine ("LOB Test END.");
- Wait ("");
- Console.WriteLine ("Read Simple Test BEGIN - scott.emp...");
- ReadSimpleTest(con1, "SELECT e.*, e.rowid FROM scott.emp e");
- Console.WriteLine ("Read Simple Test END - scott.emp");
- Wait ("");
-
- Console.WriteLine ("DataAdapter Test BEGIN...");
- DataAdapterTest(con1);
- Console.WriteLine ("DataAdapter Test END.");
- Wait ("");
- Console.WriteLine ("DataAdapter Test 2 BEGIN...");
- DataAdapterTest2(con1);
- Console.WriteLine ("DataAdapter Test 2 END.");
- Wait ("");
- Console.WriteLine ("Rollback Test BEGIN...");
- RollbackTest(con1);
- Console.WriteLine ("Rollback Test END.");
- Wait ("");
- Console.WriteLine ("Commit Test BEGIN...");
- CommitTest(con1);
- Console.WriteLine ("Commit Test END.");
- Wait ("");
- Console.WriteLine ("Parameter Test BEGIN...");
- ParameterTest(con1);
- ReadSimpleTest(con1, "SELECT * FROM MONO_TEST_TABLE7");
- Console.WriteLine ("Parameter Test END.");
- Wait ("");
-
- Console.WriteLine ("Stored Proc Test 1 BEGIN...");
- StoredProcedureTest1 (con1);
- ReadSimpleTest(con1, "SELECT * FROM MONO_TEST_TABLE1");
- Console.WriteLine ("Stored Proc Test 1 END...");
- Wait ("");
- Console.WriteLine ("Stored Proc Test 2 BEGIN...");
- StoredProcedureTest2 (con1);
- ReadSimpleTest(con1, "SELECT * FROM MONO_TEST_TABLE2");
- Console.WriteLine ("Stored Proc Test 2 END...");
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 1 BEGIN...");
- OutParmTest1 (con1);
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 1 END...");
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 2 BEGIN...");
- OutParmTest2 (con1);
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 2 END...");
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 3 BEGIN...");
- OutParmTest3 (con1);
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 3 END...");
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 4 BEGIN...");
- OutParmTest4 (con1);
- Console.WriteLine ("Out Parameter and PL/SQL Block Test 4 END...");
- Wait ("");
- Console.WriteLine ("Test a Non Query using Execute Reader BEGIN...");
- TestNonQueryUsingExecuteReader (con1);
- Console.WriteLine ("Test a Non Query using Execute Reader END...");
- Wait ("");
- Console.WriteLine ("Null Aggregate Warning BEGIN test...");
- NullAggregateTest (con1);
- Console.WriteLine ("Null Aggregate Warning END test...");
- Console.WriteLine ("Ref Cursor BEGIN tests...");
- RefCursorTests (con1);
- Console.WriteLine ("Ref Cursor END tests...");
- Console.WriteLine("Closing...");
- con1.Close ();
- Console.WriteLine("Closed.");
- conStr = conStr + ";pooling=true;min pool size=4;max pool size=" + MAX_CONNECTIONS.ToString ();
- ConnectionPoolingTest1 ();
ConnectionPoolingTest2 ();
- // Need to have an external authentication user setup in Linux and oracle
- // before running this test
- //ExternalAuthenticationTest();
- TestPersistSucurityInfo1();
- TestPersistSucurityInfo2();
- TestPersistSucurityInfo3();
- TestPersistSucurityInfo4();
- TestPersistSucurityInfo5();
- TestPersistSucurityInfo6();
-
- Console.WriteLine("Done.");
- }
- }
- }
|