zoukankan      html  css  js  c++  java
  • 另一个ado工具类

    using System;
    using System.Collections.Generic;
    using System.Text;
    using System.Data.SqlClient;
    using System.Data;
    using DC.BE.Entity;

    namespace DC.BE.BusinessImpl
    {
    public static class DBHelper
    {
    private static SqlConnection connection;
    public static SqlConnection Connection
    {
    get
    {
    string connectionString = ConnectionHelper.ConnectionString;
    if (connection == null)
    {
    connection = new SqlConnection(connectionString);
    connection.Open();
    }
    else if (connection.State == System.Data.ConnectionState.Closed)
    {
    connection.Open();
    }
    else if (connection.State == System.Data.ConnectionState.Broken)
    {
    connection.Close();
    connection.Open();
    }
    return connection;
    }
    }

    public static void BulkInsert(DataTable dt,string tableName)
    {
    using (SqlBulkCopy bulk = new SqlBulkCopy(connection))
    {
    bulk.BatchSize = 20000;
    bulk.BulkCopyTimeout = 500000000;
    bulk.DestinationTableName = tableName;

    foreach (DataColumn dc in dt.Columns)
    {
    bulk.ColumnMappings.Add(dc.ColumnName, dc.ColumnName);
    }

    bulk.WriteToServer(dt);
    }
    }

    public static int ExecuteCommand(string safeSql)
    {
    SqlCommand cmd = new SqlCommand(safeSql, Connection);
    int result = cmd.ExecuteNonQuery();
    return result;
    }

    public static int ExecuteCommand(string sql, params SqlParameter[] values)
    {
    SqlCommand cmd = new SqlCommand(sql, Connection);
    cmd.Parameters.AddRange(values);
    return cmd.ExecuteNonQuery();
    }

    public static int GetScalar(string safeSql)
    {
    SqlCommand cmd = new SqlCommand(safeSql, Connection);
    int result = Convert.ToInt32(cmd.ExecuteScalar());
    return result;
    }

    public static int GetScalar(params SqlParameter[] values)
    {
    SqlCommand cmd = new SqlCommand();
    cmd.Connection = Connection;
    cmd.CommandText = "Pro_InsertOrder";
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.AddRange(values);
    int result = Convert.ToInt32(cmd.ExecuteScalar());
    return result;
    }

    public static int GetScalar(string sql, params SqlParameter[] values)
    {
    SqlCommand cmd = new SqlCommand(sql, Connection);
    cmd.Parameters.AddRange(values);
    int result = Convert.ToInt32(cmd.ExecuteScalar());
    return result;
    }

    public static SqlDataReader GetReader(string safeSql)
    {
    SqlCommand cmd = new SqlCommand(safeSql, Connection);
    SqlDataReader reader = cmd.ExecuteReader();
    return reader;
    }

    public static SqlDataReader GetReader(string sql, params SqlParameter[] values)
    {
    SqlCommand cmd = new SqlCommand(sql, Connection);
    cmd.Parameters.AddRange(values);
    SqlDataReader reader = cmd.ExecuteReader();
    return reader;
    }

    public static DataTable GetDataSet(string safeSql)
    {
    DataSet ds = new DataSet();
    SqlCommand cmd = new SqlCommand(safeSql, Connection);
    SqlDataAdapter da = new SqlDataAdapter(cmd);
    da.Fill(ds);
    return ds.Tables[0];
    }

    public static DataTable GetDataSet(string sql, params SqlParameter[] values)
    {
    DataSet ds = new DataSet();
    SqlCommand cmd = new SqlCommand(sql, Connection);
    cmd.Parameters.AddRange(values);
    SqlDataAdapter da = new SqlDataAdapter(cmd);
    da.Fill(ds);
    return ds.Tables[0];
    }
    }
    }

    萌橙 你瞅啥?
  • 相关阅读:
    【转】教你爱上Blocks(闭包)
    【转】iOS Developer:真机测试
    bzoj1231 混乱的奶牛
    bzoj2064 分裂
    洛谷P2051 中国象棋
    洛谷P2607 骑士
    洛谷P1879 玉米田
    洛谷P3694 邦邦的大合唱
    openjudge dp水题记录
    bzoj1191 超级英雄
  • 原文地址:https://www.cnblogs.com/daimaxuejia/p/7676230.html
Copyright © 2011-2022 走看看