?

一個Sql-server數(shù)據(jù)庫連接，只適合初學(xué)者哦

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

namespace DataAccess
{
??? /// <summary>
??? /// 操作數(shù)據(jù)庫公共類
??? /// </summary>
??? class SqlDataAccess : IDisposable
??? {
??????? /// <summary>
??????? /// 數(shù)據(jù)庫連接字符串
??????? /// </summary>
???????
??????? private readonly string SqlConnectionString = "連接字符串;";

??????? private SqlConnection sqlConnection;

??????? public SqlDataAccess()
??????? {
??????????? sqlConnection = new SqlConnection(SqlConnectionString);
??????? }
??????? /// <summary>
??????? /// 執(zhí)行SQL語句，并返回數(shù)據(jù)庫受影響的行數(shù)
??????? /// </summary>
??????? /// <param name="sql">SQL語句</param>
??????? /// <returns></returns>
??????? public int ExcuteNonQuery(string sql)
??????? {
??????????? SqlCommand cmd = new SqlCommand(sql, sqlConnection);
??????????? if (sqlConnection.State == ConnectionState.Closed)
??????????? {
??????????????? sqlConnection.Open();
??????????? }
??????????? int result = cmd.ExecuteNonQuery();
??????????? sqlConnection.Close();
??????????? return result;
??????? }

　　　　//如果更新的數(shù)據(jù)有特殊字符的用上面那個ExcuteNonQuery()就不行了，需要用到SqlCommand 的一個參數(shù)SqlParameter

　　　　public int ExcuteNonQuery(string sql,SqlParameter[] parameters)
??????? 　　{

??????????? SqlCommand cmd = new SqlCommand(sql, sqlConnection);
??????????? cmd.Parameters.AddRange(parameters);
??????????? if (sqlConnection.State == ConnectionState.Closed)
??????????? {
??????????????? sqlConnection.Open();
??????????? }
??????????? int count = cmd.ExecuteNonQuery();
??????????? sqlConnection.Close();
??????????? return count;
??????? 　　}

??????? /// <summary>
??????? /// 返回首行首列
??????? /// </summary>
??????? /// <param name="sql"></param>
??????? /// <returns></returns>
??????? public object ExecuteScalar(string sql)
??????? {
??????????? SqlCommand cmd = new SqlCommand(sql, sqlConnection);
??????????? if (sqlConnection.State == ConnectionState.Closed)
??????????? {
??????????????? sqlConnection.Open();
??????????? }
??????????? object result = cmd.ExecuteScalar();
??????????? sqlConnection.Close();
??????????? return result;
??????? }
??????? /// <summary>
??????? /// 獲取一個DataSet
??????? /// </summary>
??????? /// <param name="sql"></param>
??????? /// <returns></returns>
??????? public DataSet GetDataSet(string sql)
??????? {
??????????? SqlDataAdapter adapter = new SqlDataAdapter(sql, sqlConnection);
??????????? DataSet ds = new DataSet();
??????????? adapter.Fill(ds);
??????????? return ds;
??????? }

???? }
}

示例：用上面的數(shù)據(jù)庫連接類，新增一個商品，包括商品名稱和單價

string insertSql = @"INSERT INTO PRODUCTINFO
??????????????????????????????????? VALUES
??????????????????????????????????? (
??????????????????????????????????? @PRODUCTNAME,
??????????????????????????????????? @PRODUCTPRICE,

　　　　　　　　　　　　　);

SqlParameter[] parameters = new SqlParameter[]
??????????? {
??????????????? new SqlParameter("@PRODUCTNAME",商品名稱){SqlDbType=SqlDbType.NVarChar},
??????????????? new SqlParameter("@PRODUCTPRICE",商品單價){SqlDbType=SqlDbType.Money}

　　　　}

DataAccess dataAccess = new DataAccess();
??????????? int result = dataAccess.ExcuteNonQuery(insertSql, parameters);
??????????? if (result > 0)
??????????? {
??????????????? MessageBox.Show("新增成功");
??????????? }
??????????? else
??????????? {
??????????????? MessageBox.Show("新增失敗");
??????????? }

轉(zhuǎn)載于:https://www.cnblogs.com/diaojian/archive/2011/07/18/2109163.html

總結(jié)

以上是生活随笔為你收集整理的C# Ado.NET连接Sql-server的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。