db.cs

SQL数据库在App_Data下面 是sql格式的 用的时候只需要修改App_Code下面的DB字符串就可以了 有的代码我做了注释

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
//增加命名空间
using System.Data.SqlClient;

/// <summary>
/// DB 的摘要说明
/// </summary>
public class DB
{
    SqlConnection con = null;
    SqlCommand cmd = new SqlCommand();

    //DB构造函数
	public DB()
	{
        con = new SqlConnection("server=.\\SQLEXPRESS;database=vote;uid=sa;pwd=sa;");
	}

    //打开数据库连接
    public SqlConnection getCon()
    {
        if(con.State==ConnectionState.Closed)
            con.Open();
        return con;
    }

    //关闭数据库连接
    public void clear()
    {
        if(con.State==ConnectionState.Open)
            con.Close();
    }

    //取出标题
    public string executeGetReturn(string sqlcon)
    {
        cmd.Connection = getCon();
        cmd.CommandText = sqlcon;

        String result = Convert.ToString(cmd.ExecuteScalar());
        clear();
        return result;
    }

    //取出标题项目
    public SqlDataReader getSdr(string sqlcon)
    { 
        cmd.Connection=getCon();
        cmd.CommandText = sqlcon;

        SqlDataReader sdr = cmd.ExecuteReader();
        return sdr;
    }

    //将投票者的IP和投票时间写入数据库
    public int executeNonQuery(string sqlcon)
    {
        cmd.Connection = getCon();
        cmd.CommandText = sqlcon;
        int i=cmd.ExecuteNonQuery();
        clear();
        return i;
    }

    //设置投票的事物机制
    public bool executeTransaction(string[] sqlcon)
    {
        bool flag = false;
        con = getCon();
        cmd.Connection = con;

        SqlTransaction voteTransaction=con.BeginTransaction();
        try
        {
            foreach (string sql in sqlcon)
            {
                cmd.Transaction = voteTransaction;
                cmd.CommandText = sql;
                cmd.ExecuteNonQuery();
            }
            voteTransaction.Commit();
            flag = true;
        }

        catch (Exception e)
        {
            voteTransaction.Rollback();
            flag = false;
        }
        finally 
        {
            clear();
        }
        return flag;
    }

}