makeconnection.cs

内容管理 内容管理 内容管理 内容管理 内容管理

                        }
                        break;
                }
                return retString;
            }
            return null;
        }

        //*************************************************************
        //*     函数名称：SqlCommand(command)
        //*     功能描述：根据不同的execMethod参数，使用不同的方法连接数据库。(主入口)
        //*     作    者：徐宏杰
        //*     创建日期：2004.3.16
        //*     传入参数：
        //*     返回参数：
        //*     备    注：
        //*************************************************************
        public object MakeConnectionSqlCommand(System.Data.SqlClient.SqlCommand sqlCommand, DAL.clsDBConnkey ConnkeyWord, executeMethod execMethod, EnumDBType DataType)
        {
            String strConnection = "", retString = "",sql="";
            DataSet mydataset1 = null;
            strConnection = MakeConnectionString(ConnkeyWord, DataType, "");

            //返回dataSet
            if( strConnection != "" && execMethod == executeMethod.execute_DataSet)
            {
                switch (DataType)
                {
                    case EnumDBType.Sql:
                        SqlConnection conn =null;
                        try
                        {
                            SqlDataAdapter apater =null;
                             mydataset1 = new DataSet();
                            conn = new SqlConnection(strConnection);
                            conn.Open();
                            sqlCommand.Connection = conn;

                            apater = new SqlDataAdapter(sqlCommand);
                            apater.Fill(mydataset1, "form");
                            conn.Close();
                            if (conn!=null) conn.Dispose();
                            
                        }
                        catch(System.Exception ex)
                        {
                            if (conn!=null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return  mydataset1;
            }

            //添加、删除、修改
            if( strConnection != "" && execMethod == executeMethod.execute_NoneQuery)
            {
                switch (DataType)
                {
                    case EnumDBType.Sql:
                        SqlConnection conn=null ;
                        try
                        {
                            
                            DataSet mydataset2 =new DataSet();
                            conn = new SqlConnection(strConnection);
                            conn.Open();
                            sqlCommand.Connection = conn;

                            sqlCommand.ExecuteNonQuery();
                            conn.Close();
                            if (conn!=null) conn.Dispose();
                            
                        }
                        catch(System.Exception ex)
                        {
                            if (conn!=null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return null;
            }
 

            //返回关键字第一行记录的arraylist。
            if(strConnection != "" && execMethod == executeMethod.execute_Linekey)
            {
                System.Collections.ArrayList arraylistItem = null;
                switch (DataType)
                {
                    case EnumDBType.Sql:
                        SqlConnection sqlconn = null;
                        try
                        {
                            arraylistItem = new System.Collections.ArrayList();
                            SqlDataAdapter apater;
                            mydataset1 = new DataSet();
                            sqlconn = new SqlConnection(strConnection);
                            sqlconn.Open();

                            apater = new SqlDataAdapter(sql, sqlconn);
                            apater.Fill(mydataset1, "form");
                            for (int i = 0; i < mydataset1.Tables["form"].Columns.Count; i++)
                            {
                                arraylistItem.Add(mydataset1.Tables["form"].Rows[0][i]);
                            }
                            sqlconn.Close();
                            if (sqlconn != null) sqlconn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (sqlconn != null) sqlconn.Dispose();
                            throw ex;
                        }
                        break;
                 }
                 return arraylistItem;
            }

            //首条记录
            if (strConnection != "" && execMethod == executeMethod.execute_Scalar)
            {
               switch (DataType)
                {
                    case EnumDBType.Sql:
                        SqlConnection sqlconn = null;
                        try
                        {
                            retString = "";
                            mydataset1 = new DataSet();
                            sqlconn = new SqlConnection(strConnection);
                            sqlconn.Open();

                            SqlCommand command = new SqlCommand(sql, sqlconn);
                            retString = Convert.ToString(command.ExecuteScalar());
                            sqlconn.Close();
                            if (sqlconn != null) sqlconn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (sqlconn != null) sqlconn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return retString;
            }

            return null;
        }



        //*************************************************************
        //*     函数名称：SqlCommand(command)
        //*     功能描述：根据不同的execMethod参数，使用不同的方法连接数据库。(主入口)
        //*     作    者：徐宏杰
        //*     创建日期：2004.3.16
        //*     传入参数：
        //*     返回参数：
        //*     备    注：
        //*************************************************************
        public object MakeConnectionOledbCommand(System.Data.OleDb.OleDbCommand oledbCommand,DAL.clsDBConnkey  ConnkeyWord ,executeMethod execMethod ,EnumDBType DataType,string WebVirtualPath )
        {
            String strConnection = "", retString = "", sql = "";
            DataSet mydataset1 = null;
            strConnection = MakeConnectionString(ConnkeyWord, DataType, WebVirtualPath);

            //返回dataSet
            if (strConnection != "" && execMethod == executeMethod.execute_DataSet)
            {
                switch (DataType)
                {
                    case EnumDBType.Oledb :
                        OleDbConnection  conn = null;
                        try
                        {
                            OleDbDataAdapter apater = null;
                            mydataset1 = new DataSet();
                            conn = new OleDbConnection(strConnection);
                            conn.Open();
                            oledbCommand.Connection = conn;

                            apater = new OleDbDataAdapter(oledbCommand);
                            apater.Fill(mydataset1, "form");
                            conn.Close();
                            if (conn != null) conn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (conn != null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return mydataset1;
            }

            //添加、删除、修改
            if (strConnection != "" && execMethod == executeMethod.execute_NoneQuery)
            {
                switch (DataType)
                {
                    case EnumDBType.Oledb :
                        OleDbConnection conn = null;
                        try
                        {
                            
                            mydataset1 = new DataSet();
                            conn = new OleDbConnection(strConnection);
                            conn.Open();
                            oledbCommand.Connection = conn;
                            oledbCommand.ExecuteNonQuery();
                            conn.Close();
                            if (conn != null) conn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (conn != null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return null;
            }


            //返回关键字第一行记录的arraylist。
            if (strConnection != "" && execMethod == executeMethod.execute_Linekey)
            {
                System.Collections.ArrayList arraylistItem = null;
                switch (DataType)
                {
                    case EnumDBType.Oledb:
                        OleDbConnection conn = null;
                        try
                        {
                            arraylistItem = new System.Collections.ArrayList();
                            OleDbDataAdapter apater;
                            mydataset1 = new DataSet();
                            conn = new OleDbConnection(strConnection);
                            conn.Open();

                            apater = new OleDbDataAdapter(sql, conn);
                            apater.Fill(mydataset1, "form");
                            conn.Close();
                            for (int i = 0; i < mydataset1.Tables["form"].Columns.Count; i++)
                            {
                                arraylistItem.Add(mydataset1.Tables["form"].Rows[0][i]);
                            }
                            if (conn != null) conn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (conn != null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return arraylistItem;
            }

            //首条记录
            if (strConnection != "" && execMethod == executeMethod.execute_Scalar)
            {
                switch (DataType)
                {
                    case EnumDBType.Oledb:
                        OleDbConnection conn = null;
                        try
                        {
                            retString = "";
                            mydataset1 = new DataSet();
                            conn = new OleDbConnection(strConnection);
                            conn.Open();

                            OleDbCommand command = new OleDbCommand(sql, conn);
                            retString = Convert.ToString(command.ExecuteScalar());
                            conn.Close();
                            if (conn != null) conn.Dispose();

                        }
                        catch (System.Exception ex)
                        {
                            if (conn != null) conn.Dispose();
                            throw ex;
                        }
                        break;
                }
                return retString;
            }

            return null;
        }





    }
}