Friday, November 11, 2022

Oracle connection string , read, write query in ASP.NET

 using Oracle.ManagedDataAccess.Client;

using System;

using System.Collections.Generic;

using System.Data;

using System.Data.SqlClient;

using System.Linq;

using System.Web;


namespace cadre_mgmt_system.DataRepository

{

    public class OracleDAL

    {

        //public static readonly string connectionString = ConfigurationManager.ConnectionStrings["OracleConn"].ConnectionString;

        OracleConnection conn;

        public OracleDAL()

        {

            conn = new OracleConnection("user id=readonly;password=readonly;data source=192.168.101.29:1522/PROD");

        }

        //public DataSet Read(string StoredProcedure, SqlParameter[] param)

        //{

        //    OracleCommand cmd = new OracleCommand(StoredProcedure, conn);

        //    cmd.CommandType = CommandType.StoredProcedure;

        //    if (param != null)

        //        cmd.Parameters.AddRange(param.ToArray());

        //    OracleDataAdapter da = new OracleDataAdapter(cmd);

        //    DataSet ds = new DataSet();

        //    conn.Open();

        //    da.Fill(ds);

        //    conn.Close();

        //    return ds;

        //}

        public DataSet Read(string Query)

        {

            //Query = "select * from XXICAR_EMPLOYEE_BANK_DETAILS";

            OracleCommand cmd = new OracleCommand(Query, conn);

            OracleDataAdapter da = new OracleDataAdapter(cmd);

            DataSet ds = new DataSet();

            conn.Open();

            da.Fill(ds);

            conn.Close();

            return ds;

        }

        public bool Write(string Query)

        {

            OracleCommand cmd = new OracleCommand(Query, conn);

            cmd.CommandType = CommandType.Text;

            conn.Open();

            int rows = cmd.ExecuteNonQuery();

            conn.Close();

            if (rows == 1)

                return true;

            else

                return false;

        }

        public bool Write(string StoredProcedure, SqlParameter[] param = null)

        {

            OracleCommand cmd = new OracleCommand(StoredProcedure, conn);

            cmd.CommandType = CommandType.StoredProcedure;

            if (param != null)

                cmd.Parameters.AddRange(param.ToArray());

            conn.Open();

            int rows = cmd.ExecuteNonQuery();

            conn.Close();

            if (rows == 1)

                return true;

            else

                return false;

        }

    }

}


--------------------------------------------------------

or from bokaro


 public List<PlatformData> GetStationPlatformReport(string userid, out string errmsg)
        {
            OracleConnection connection = null;

            List<PlatformData> PlatformDataReport = null;
            try
            {
                connection = RepositoryConnectionManager.Instance.CreateConnection();
                OracleCommand OraCmd = new OracleCommand("REPORTS.GetStationPlatform", connection);
                OraCmd.CommandType = System.Data.CommandType.StoredProcedure;
                OraCmd.Parameters.Add(new OracleParameter("OUT_CURSOR", OracleDbType.RefCursor, ParameterDirection.Output));
                PlatformDataReport = new List<PlatformData>();
                Logfile.LogMain("REPORTS.GetStationPlatform", userid);
                connection.Open();



                using (IDataReader reader = OraCmd.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        PlatformData Platform = new PlatformData();

                        if (reader["DVSNCODE"] != null)
                        {
                            Platform.ZoneCode = reader["ZONECODE"].ToString();
                            Platform.DvsnCode = reader["DVSNCODE"].ToString();
                            Platform.StationCode = reader["STTNCODE"].ToString();
                            Platform.PlatformNumber = reader["PLATFORMNUMB"].ToString();
                            Platform.PlatformType = reader["PFTYPE"].ToString();
                            //Platform.SuburbanFlag = reader["SUBURBANFLAG"].ToString();
                            Platform.IsSuburbanTraffic = reader["SUBURBANFLAG"].ToString().ToUpper() == "Y" ? true : false;
                            Platform.IsAllTraffic = reader["SUBURBANFLAG"].ToString().ToUpper() == "N" ? true : false;
                            Platform.Length = reader["LENGTH"].ToString();
                            Platform.Capacity = reader["CAPACITY"].ToString();
                            //Platform.Facility = reader["FACILITY"].ToString();
                            Platform.IsFacilityFL = reader["FACILITY"].ToString().Contains("FL") ? true : false;
                            Platform.IsFacilityWT = reader["FACILITY"].ToString().Contains("WT") ? true : false;
                            Platform.IsFacilityCH = reader["FACILITY"].ToString().Contains("CH") ? true : false;
                            Platform.IsFacilityFB = reader["FACILITY"].ToString().Contains("FB") ? true : false;
                            Platform.IsFacilityWC = reader["FACILITY"].ToString().Contains("WC") ? true : false;
                        }

                        PlatformDataReport.Add(Platform);
                    }
                }
                errmsg = "";
                return PlatformDataReport;
            }
            catch (OracleException e)
            {
                Logfile.LogMain(e.Procedure + " :- Message: " + e.Message, userid);
                Console.WriteLine(e.Procedure + " :- Message: " + e.Message);
                errmsg = e.Message;
                return PlatformDataReport;
            }
            catch (Exception e)
            {
                Logfile.LogMain("REPORTS.GetStationPlatform :- " + e.Message, userid);
                Console.WriteLine("REPORTS.GetStationPlatform :- " + e.Message);
                errmsg = e.Message;
                return PlatformDataReport;
            }

            finally
            {
                if (connection != null && connection.State == ConnectionState.Open)
                {
                    connection.Close();
                }
            }
        }



No comments:

Post a Comment