commonfuntion.cs

1。使用ASP.NET+C# VS.NET 2003制作

using System;
using System.Data.SqlClient;
using System.Data;

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

		public static int getNewTableID(String TableName)
		{
			//获取新序号
			int r=0;

			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);
		}
	}
}