dbexec.cs

asp.net 2.0的教务管理软件源码

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Text;

using System.Configuration;
//该源码下载自www.51aspx.com(５１ａｓｐｘ．ｃｏｍ)
public class DBExec
{
    private static String connStr = ConfigurationManager.ConnectionStrings["keke100ConnectionString"].ConnectionString;

    public static void ExecNonQuery(string sql)
    {
        SqlConnection conn = new SqlConnection(connStr);
        conn.Open();
        SqlCommand sc = new SqlCommand(sql, conn);
        sc.ExecuteNonQuery();
        conn.Close();
    }
    public static void ExecParamQuery(string sql, List<SqlParameter> sp)
    {
        SqlConnection conn = new SqlConnection(connStr);
        SqlCommand sc = new SqlCommand(sql, conn);
        sc.CommandType = CommandType.Text;
        foreach (SqlParameter s in sp)
        {
            sc.Parameters.Add(s);
        }
        conn.Open();
        sc.ExecuteNonQuery();
    }

    public static void ExecNonQuery(string sql, List<SqlParameter> sp)
    {
        SqlConnection conn = new SqlConnection(connStr);
        SqlCommand sc = new SqlCommand(sql, conn);
        sc.CommandType = CommandType.StoredProcedure;
        foreach (SqlParameter s in sp)
        {
            sc.Parameters.Add(s);
        }
        conn.Open();
        sc.ExecuteNonQuery();
    }

    public static int ExecGetInt(string sql, List<SqlParameter> sp)
    {
        int i = 0;
        SqlConnection conn = new SqlConnection(connStr);
        SqlCommand sc = new SqlCommand(sql, conn);
        sc.CommandType = CommandType.StoredProcedure;
        foreach (SqlParameter s in sp)
        {
            sc.Parameters.Add(s);
        }
        conn.Open();
        SqlDataReader sdr = sc.ExecuteReader();
        if (sdr.Read())
            i = Convert.ToInt32(sdr[0]);
        conn.Close();
        return i;
    }

    //得到单一值的sql语句
    public static int ExecGetInt(String sql)
    {
        int i = 0;
        SqlConnection conn = new SqlConnection(connStr);
        SqlCommand sc = new SqlCommand(sql, conn);
        conn.Open();
        SqlDataReader sdr = sc.ExecuteReader();
        if (sdr.Read() && sdr[0] != DBNull.Value)
            i = Convert.ToInt32(sdr[0]);
        conn.Close();
        return i;
    }

    public static object ExecGetObject(String sql)
    {
        object o = 0;
        SqlConnection conn = new SqlConnection(connStr);
        SqlCommand sc = new SqlCommand(sql, conn);
        conn.Open();
        SqlDataReader sdr = sc.ExecuteReader();
        if (sdr.Read())
            o = sdr[0];
        conn.Close();
        return o;
    }

    public static DataTable ExecDataTable(string sql)
    {
        SqlConnection conn = new SqlConnection(connStr);
        DataSet ds = new DataSet();
        SqlDataAdapter sda = new SqlDataAdapter(sql, conn);
        sda.Fill(ds, "MyTable");
        conn.Close();
        return ds.Tables[0];
    }

    public static DataSet ExecDataSet(string sql)
    {
        SqlConnection conn = new SqlConnection(connStr);
        DataSet ds = new DataSet();
        SqlDataAdapter sda = new SqlDataAdapter(sql, conn);
        sda.Fill(ds, "MyTable");
        conn.Close();
        return ds;
    }
}