commonfuntion.cs

勇敢者论坛全部源代码。 支持SQL2000/Access数据库

using System;
using System.Data.SqlClient;
using System.Data;
using System.Data.OleDb;
using System.Configuration;

namespace doughty_cn
{
	/// <summary>
	/// CommonFuntion 的摘要说明。
	/// </summary>
	public class CommonFuntion
	{
		public CommonFuntion()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}

        public static int getNewTableID(String TableName)
        {
            //获取新序号
            int r = 0;
            string DBtype = ConfigurationManager.AppSettings["DBtype"];
            if (DBtype == "Accsee")
            {
                DBsql exsql = new DBsql();
                exsql.Open();
                OleDbCommand selectCommandac = new OleDbCommand("SELECT autoid FROM sq WHERE (tablename = @tablename)", exsql.con);
                OleDbCommand updateCommandac = new OleDbCommand("UPDATE sq SET autoid = autoid + 1 WHERE (tablename = @tablename)", exsql.con);
                OleDbCommand insertCommandac = new OleDbCommand("INSERT INTO sq (tablename, autoid) VALUES (@tablename, 0)", exsql.con);
                selectCommandac.Parameters.Add("@tablename", OleDbType.VarChar, 32);
                updateCommandac.Parameters.Add("@tablename", OleDbType.VarChar, 32);
                insertCommandac.Parameters.Add("@tablename", OleDbType.VarChar, 32);

                OleDbTransaction myTransac = exsql.con.BeginTransaction();

                selectCommandac.Transaction = myTransac;
                updateCommandac.Transaction = myTransac;
                insertCommandac.Transaction = myTransac;
                try
                {
                    selectCommandac.Parameters["@tablename"].Value = TableName;
                    updateCommandac.Parameters["@tablename"].Value = TableName;
                    insertCommandac.Parameters["@tablename"].Value = TableName;

                    OleDbDataReader myReaderac = selectCommandac.ExecuteReader();
                    if (myReaderac.HasRows)
                    {
                        myReaderac.Read();
                        r = myReaderac.GetInt32(0);
                        r++;
                        myReaderac.Close();
                    }
                    else
                    {
                        myReaderac.Close();
                        insertCommandac.ExecuteNonQuery();
                        r = 1;
                    }

                    updateCommandac.ExecuteNonQuery();
                    myTransac.Commit();
                }
                catch (Exception)
                {
                    try
                    {
                        myTransac.Rollback();
                    }
                    catch (SqlException)
                    {
                        if (myTransac.Connection != null)
                        {
                            //		Console.WriteLine("An exception of type " + ex.GetType() +
                            //			" was encountered while attempting to roll back the transaction.");
                        }
                    }
                    throw new Exception("获取新序号失败！");
                }
                finally
                {
                    exsql.Close();
                }
            }
            else
            {
                SqlConnection myConnection = new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["DBConnection"]);
                SqlCommand selectCommand = new SqlCommand("SELECT autoid FROM sq WITH (ROWLOCK) WHERE (tablename = @tablename)", myConnection);
                SqlCommand updateCommand = new SqlCommand("UPDATE sq SET autoid = autoid + 1 WHERE (tablename = @tablename)", myConnection);
                SqlCommand insertCommand = new SqlCommand("INSERT INTO sq (tablename, autoid) VALUES (@tablename, 0)", myConnection);

                selectCommand.Parameters.Add("@tablename", SqlDbType.NVarChar, 32);
                updateCommand.Parameters.Add("@tablename", SqlDbType.NVarChar, 32);
                insertCommand.Parameters.Add("@tablename", SqlDbType.NVarChar, 32);

                myConnection.Open();
                SqlTransaction myTrans = myConnection.BeginTransaction();

                selectCommand.Transaction = myTrans;
                updateCommand.Transaction = myTrans;
                insertCommand.Transaction = myTrans;
                try
                {
                    selectCommand.Parameters["@tablename"].Value = TableName;
                    updateCommand.Parameters["@tablename"].Value = TableName;
                    insertCommand.Parameters["@tablename"].Value = TableName;

                    SqlDataReader myReader = selectCommand.ExecuteReader();
                    if (myReader.HasRows)
                    {
                        myReader.Read();
                        r = myReader.GetInt32(0);
                        r++;
                        myReader.Close();
                    }
                    else
                    {
                        myReader.Close();
                        insertCommand.ExecuteNonQuery();
                        r = 1;
                    }

                    updateCommand.ExecuteNonQuery();
                    myTrans.Commit();
                }
                catch (Exception)
                {
                    try
                    {
                        myTrans.Rollback();
                    }
                    catch (SqlException)
                    {
                        if (myTrans.Connection != null)
                        {
                            //		Console.WriteLine("An exception of type " + ex.GetType() +
                            //			" was encountered while attempting to roll back the transaction.");
                        }
                    }
                    throw new Exception("获取新序号失败！");
                }
                finally
                {
                    myConnection.Close();
                }
            }
            return r;
        }
	
		public static string getAffiche(int BigClass_ID,int SmallClass_ID)
		{
			//获取公告信息
			string r="",sql;
			if (SmallClass_ID==0)
				sql="SELECT affiche FROM affiche WHERE (BigClass_ID = "+BigClass_ID.ToString()+")";
			else
				sql="SELECT affiche FROM affiche WHERE (BigClass_ID = "+BigClass_ID.ToString()
					+") AND (SmallClass_ID = "+SmallClass_ID.ToString()+")";
			DataRow dr=DBOperate.GetDataRow(sql,"affiche","DBConnection");
			r=dr["affiche"].ToString();
			return r;  
		}

		public static void setAffiche(int BigClass_ID,int SmallClass_ID,string Affiche)//获取公告信息
		{
			//设置公告信息
			string sql;
			if (SmallClass_ID==0)
				sql="UPDATE affiche SET affiche = '"+Affiche+"' WHERE (BigClass_ID = "+BigClass_ID.ToString()
					+")";
			else
				sql="UPDATE affiche SET affiche = '"+Affiche+"' WHERE (BigClass_ID = "+BigClass_ID.ToString()
					+") AND (SmallClass_ID = "+SmallClass_ID.ToString()+")";
			DBOperate.ExcSQL(sql);
		}
	}
}