sort.cs

一个在线的音乐榜单的系统

using System;
using System.Data;
using System.Data.OracleClient;
namespace MusicClass
{
	/// <summary>
	/// Sort 的摘要说明。
	/// </summary>
	public class Sort
	{
		private string _songid;
		private string _description;
		private string _submittime;
		private string _userid;

		public string SongId
		{
			set { _songid = value;}
			get { return _songid;}
		}
		public string Description
		{
			set {_description = value;}
			get { return _description;}
		}
		public string SubmitTime
		{
			set { _submittime = value;}
			get { return _submittime;}
		}
		public string UserId
		{
			set { _userid = value;}
			get { return _userid;}
		}

		public Sort()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}
		public static int InsertSortRecord(string songid,string description,string submittime,string userid)
		{
			OracleConnection conn = new OracleConnection(System.Configuration.ConfigurationSettings.AppSettings["OraConnString"]);
			string judge = "SELECT COUNT(*) FROM PopMusic.Sort WHERE songid='"+songid+"' AND to_char(submitDate,'rrrr-mm')=to_char(to_date('"+submittime+"','rrrr-mm-dd hh24:mi:ss'),'rrrr-mm') AND userid='"+userid+"'";
			OracleCommand commJudge = new OracleCommand(judge,conn);
			try
			{
				conn.Open();
				object result = commJudge.ExecuteScalar();
				
				if (int.Parse(result.ToString()) >= 1)
					return -1;
				string sql = "INSERT INTO PopMusic.Sort Values('"+songid+"','"+description+"',to_date('"+submittime+"','rrrr-mm-dd hh24:mi:ss'),'"+userid+"')";
				OracleCommand comm = new OracleCommand(sql,conn);				
				return comm.ExecuteNonQuery();
			}
			finally
			{
				conn.Close();
			}
		}
		public static int DeleteSortRecord(string songid,string submittime,string userid)
		{
			OracleConnection conn = new OracleConnection(System.Configuration.ConfigurationSettings.AppSettings["OraConnString"]);
			string sql = "DELETE FROM PopMusic.Sort WHERE songid='"+songid+"' AND to_char(submittime,'rrrr-mm') = to_char(to_date("+submittime+",'rrrr-mm-dd'),'rrrr-mm')" +" AND userid='"+userid+"'";
			OracleCommand comm = new OracleCommand(sql,conn);
			try
			{
				conn.Open();
				return comm.ExecuteNonQuery();
			}
			finally
			{
				conn.Close();
			}
		}
	}
}