<del id="cy8wi"></del>

<bdo id="cy8wi"><center id="cy8wi"></center></bdo>

DbSqlLiteData 數據庫連接類

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Collections;
using System.Data.SQLite;
using System.Data.Common;
namespace Common.Dba
{
    class DbSqlLiteData:DbAccess
    {
         new SQLiteCommand cmd = null;
        public DbSqlLiteData()
        {
            //
            // TODO: 在此處添加構造函數邏輯
            //
            conn = new SQLiteConnection();
            conn.ConnectionString = ConnectionString;//Convert.ToString(ConfigurationManager.AppSettings["datasource"]); //Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
            //conn.ConnectionString = "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt;Connect Timeout=5000";
            cmd = new SQLiteCommand();
            cmd.Connection = conn as SQLiteConnection;
            cmd.CommandTimeout = 0;

        }
        public DbSqlLiteData(string constr)
        {

            //
            // TODO: 在此處添加構造函數邏輯
            //
            conn = new SQLiteConnection();
            //conn.ConnectionString = "initial catalog=pubs;data source=.;user id=sa;password=";
            //conn.ConnectionString = Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
            conn.ConnectionString = constr;// "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt";
            cmd = new SQLiteCommand();
            cmd.Connection = conn as SQLiteConnection;
            cmd.CommandTimeout = 0;

        }
        /// <summary>
        /// 獲取數據根據Sql語句
        /// </summary>
        /// <param name="Sql"></param>
        /// <returns></returns>
        public override DataTable GetTable(string sql)
        {
            DataSet ds = new DataSet();

            try
            {
                cmd.CommandText = sql;
                cmd.CommandType = CommandType.Text;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;
                da.Fill(ds);
            }
            catch (Exception ex)
            {

return null;

            }
            return ds.Tables[0] ?? new DataTable();
        }
        /// <summary>
        /// 獲取數據根據sql語句
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public override DataSet GetDataSet(string sql)
        {
            DataSet ds = new DataSet();

            try
            {
                cmd.CommandText = sql;
                cmd.CommandType = CommandType.Text;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;

                da.Fill(ds);
            }
            catch (Exception ex)
            {

return null;

            }
            return ds;
        }
        /// <summary>
        /// 獲取數據根據sql語句
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public override DataSet GetDataSet(string sql, DbParameter[] pas)
        {
            DataSet ds = new DataSet();

            try
            {
                cmd.Parameters.Clear();
                cmd.CommandText = sql;
                foreach (SQLiteParameter pa in pas)
                {
                    cmd.Parameters.Add(pa);
                }
                cmd.CommandType = CommandType.Text;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;

                da.Fill(ds);
            }
            catch (Exception ex)
            {

return null;

            }
            return ds;
        }
        /// <summary>
        /// 獲取數據根據sql語句帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override DataTable GetTable(string sql, params DbParameter[] pas)
        {
            DataSet ds = new DataSet();
            try
            {
                cmd.CommandText = sql;
                cmd.CommandType = CommandType.Text;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }

                da.Fill(ds);
            }
            catch (Exception ex)
            {

                return null;
            }
            return ds.Tables[0] ?? new DataTable();
        }
        /// <summary>
        /// 獲取數據根據sql語句帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override DataTable GetProcTable(string procname, params DbParameter[] pas)
        {
            DataSet ds = new DataSet();
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = procname;
                //cmd.CommandText = sql;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }

                da.Fill(ds);
            }
            catch (Exception ex)
            {

                return null;
            }
            return ds.Tables[0] ?? new DataTable();
        }
        /// <summary>
        /// 獲取數據根據sql語句帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override DataTable GetProcCursorTable(string procname, params DbParameter[] pas)
        {
            DataSet ds = new DataSet();
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = procname;
                //cmd.CommandText = sql;
                SQLiteDataAdapter da = new SQLiteDataAdapter();
                da.SelectCommand = cmd;
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }

                da.Fill(ds);
            }
            catch (Exception ex)
            {

                return null;
            }
            return ds.Tables[1] ?? new DataTable();
        }
        /// <summary>
        /// 獲取數據根據sql語句帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override int GetProcState(string procname, params DbParameter[] pas)
        {
            int state = 0;
            try
            {
                OpenConn();
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = procname;
                cmd.Parameters.Clear();
                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }
                cmd.ExecuteNonQuery();
                CloseConn();
                state = Convert.ToInt32(pas[pas.Length - 1].Value);

            }
            catch
            {
                return 0;
            }
            return state;
        }
        /// <summary>
        /// 獲取數據根據sql語句帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override int GetProcStateNo(string procname, params DbParameter[] pas)
        {
            int state = 0;
            try
            {
                OpenConn();
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = procname;
                cmd.Parameters.Clear();
                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }
                cmd.ExecuteNonQuery();
                CloseConn();
                state = 1;

// state = Convert.ToInt32(pas[pas.Length - 1].Value);

            }
            catch
            {

                return 0;
            }
            return state;
        }
        /// <summary>
        /// 存儲過程返回值的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override string GetProcStateReturnValue(string procname, params DbParameter[] pas)
        {
            string state = "";
            try
            {
                OpenConn();
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = procname;
                cmd.Parameters.Clear();
                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }
                cmd.Parameters.AddWithValue("@Return_Value", "").Direction = ParameterDirection.ReturnValue;
                cmd.ExecuteNonQuery();
                state = Convert.ToString(cmd.Parameters["@Return_Value"].Value);
                state = state == null ? ("") : (state);
                CloseConn();

// state = Convert.ToInt32(pas[pas.Length - 1].Value);

            }
            catch
            {

                return "";
            }
            return state;
        }
        /// <summary>
        /// 根據sql語句返回跟新狀態
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public override bool GetState(string sql)
        {
            bool succ = false;
            try
            {
                cmd.CommandType = CommandType.Text;
                cmd.CommandText = sql;
                OpenConn();
                succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
                CloseConn();
            }
            catch (Exception ex)
            {

                return false;
            }
            return succ;

        }
        /// <summary>
        /// 根據sql語句返回跟新狀態帶參數的
        /// </summary>
        /// <param name="sql">sql語句</param>
        /// <param name="pas">參數的集合</param>
        /// <returns></returns>
        public override bool GetState(string sql, params DbParameter[] pas)
        {
            bool succ = false;
            try
            {
                cmd.CommandType = CommandType.Text;
                cmd.CommandText = sql;
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }
                OpenConn();
                succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
                CloseConn();
            }
            catch
            {

                // this.ShowError(ex.Message);
                //using (System.IO.StreamWriter sw = new System.IO.StreamWriter("D:\\error2008.txt"))
                //{
                //    sw.Write(ex.Message);
                //    sw.Flush();
                //}
                return false;
            }
            return succ;

        }
        /// <summary>
        /// 根據sql語句返回第一個單元格的數據
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public override string GetOne(string sql)
        {
            string res = "";
            try
            {
                cmd.CommandType = CommandType.Text;
                cmd.CommandText = sql;
                OpenConn();
                res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
                CloseConn();
            }
            catch (Exception ex)
            {

                return null;
            }
            return res;
        }
        /// <summary>
        /// 根據sql語句返回第一個單元格的數據帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override string GetOne(string sql, params DbParameter[] pas)
        {
            string res = "";
            try
            {
                cmd.CommandType = CommandType.Text;
                cmd.CommandText = sql;
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }
                OpenConn();
                res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
                CloseConn();
            }
            catch (Exception ex)
            {
                CloseConn();

                return null;
            }
            return res;
        }
        /// <summary>
        /// 返回數據的DataReader
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public override DbDataReader GetDataReader(string sql)
        {
            SQLiteDataReader dr = null;
            try
            {
                cmd.CommandType = CommandType.Text;
                conn.Open();
                cmd.CommandText = sql;
                dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            }
            catch (Exception ex)
            {

                return null;
            }
            return dr;
        }
        /// <summary>
        /// 返回數據的DataReader帶參數的
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pas"></param>
        /// <returns></returns>
        public override DbDataReader GetDataReader(string sql, params DbParameter[] pas)
        {
            SQLiteDataReader dr = null;
            try
            {
                cmd.CommandType = CommandType.Text;
                conn.Open();
                cmd.Parameters.Clear();

                foreach (SQLiteParameter temppa in pas)
                {
                    cmd.Parameters.Add(temppa);
                }

                cmd.CommandText = sql;
                dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            }
            catch (Exception ex)
            {

                return null;
            }
            return dr;
        }
        /// <summary>
        /// 事務處理函數
        /// </summary>
        /// <param name="al"></param>
        /// <returns></returns>
        public override bool GetTranState(ArrayList al)
        {
            cmd.CommandType = CommandType.Text;
            OpenConn();
            SQLiteTransaction tran = (conn as SQLiteConnection).BeginTransaction();
            cmd.Transaction = tran;
            try
            {
                for (int i = 0; i < al.Count; i++)
                {
                    cmd.CommandText = Convert.ToString(al[i]);
                    cmd.ExecuteNonQuery();
                }

                tran.Commit();
                CloseConn();
            }
            catch
            {

                tran.Rollback();
                CloseConn();
                return false;
            }
            return true;

        }

        /// <summary>
        /// 分頁函數
        /// </summary>
        /// <param name="pagesize"></param>
        /// <param name="columns"></param>
        /// <param name="tablename"></param>
        /// <param name="pid"></param>
        /// <param name="order"></param>
        /// <param name="current"></param>
        /// <returns></returns>
        public override DataTable GetPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order)
        {
            current = current - 1 >= 0 ? (current - 1) : (0);
            string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5} order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
            return GetTable(sql);

        }
        /// <summary>
        /// 分頁存儲過程的調用
        /// </summary>
        /// <param name="current"></param>
        /// <param name="pagesize"></param>
        /// <param name="columns"></param>
        /// <param name="tablename"></param>
        /// <param name="pid"></param>
        /// <param name="where"></param>
        /// <param name="order"></param>
        /// <returns></returns>
        public override DataTable GetProcPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string ordertype)
        {
            SQLiteParameter[] pas = { new SQLiteParameter("@PageIndex", current), new SQLiteParameter("@PageSize", pagesize), new SQLiteParameter("@Columns", columns), new SQLiteParameter("@Tablename", tablename), new SQLiteParameter("@Where", where), new SQLiteParameter("@Order", order), new SQLiteParameter("@OrderType", ordertype), new SQLiteParameter("@Pid", pid) };
            return GetProcTable("Pages", pas);
            //current = current - 1 >= 0 ? (current - 1) : (0);
            //string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5} order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
            //return GetTable(sql);
        }
        /// <summary>
        /// 分頁存儲過程的調用
        /// </summary>
        /// <param name="current"></param>
        /// <param name="pagesize"></param>
        /// <param name="columns"></param>
        /// <param name="tablename"></param>
        /// <param name="pid"></param>
        /// <param name="where"></param>
        /// <param name="order"></param>
        /// <returns></returns>
        public override DataTable GetProcData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
        {

            SQLiteParameter[] pas = { new SQLiteParameter("@TableNames", DbType.String), new SQLiteParameter("@PrimaryKey", DbType.String), new SQLiteParameter("@Order", DbType.String), new SQLiteParameter("@CurrentPage", DbType.Int32), new SQLiteParameter("@PageSize", DbType.Int32), new SQLiteParameter("@Fields", DbType.String), new SQLiteParameter("@Filter", DbType.String), new SQLiteParameter("@ResultCount", DbType.String), new SQLiteParameter("@distinct", DbType.String) };
            pas[0].Value = tablename;
            pas[1].Value = pid;
            pas[2].Value = order;
            pas[3].Value = current;
            pas[4].Value = pagesize;
            pas[5].Value = columns;
            pas[6].Value = where;
            pas[7].Value = resultCount;
            pas[8].Value = distinct;
            return this.GetProcTable("Pages", pas);

        }
        /// <summary>
        /// 分頁存儲過程的調用
        /// </summary>
        /// <param name="current"></param>
        /// <param name="pagesize"></param>
        /// <param name="columns"></param>
        /// <param name="tablename"></param>
        /// <param name="pid"></param>
        /// <param name="where"></param>
        /// <param name="order"></param>
        /// <returns></returns>
        public override DataTable GetProcAdminData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
        {
            SQLiteParameter[] pas = { new SQLiteParameter("@TableNames", DbType.String), new SQLiteParameter("@PrimaryKey", DbType.String), new SQLiteParameter("@Order", DbType.String), new SQLiteParameter("@CurrentPage", DbType.Int32), new SQLiteParameter("@PageSize", DbType.Int32), new SQLiteParameter("@Fields", DbType.String), new SQLiteParameter("@Filter", DbType.String), new SQLiteParameter("@ResultCount", DbType.String), new SQLiteParameter("@Distinct", DbType.String) };
            pas[0].Value = tablename;
            pas[1].Value = pid;
            pas[2].Value = order;
            pas[3].Value = current;
            pas[4].Value = pagesize;
            pas[5].Value = columns;
            pas[6].Value = where;
            pas[7].Value = resultCount;
            pas[8].Value = distinct;
            return this.GetProcTable("Pages", pas);

        }
        public override DbParameter[] MakeParameters(params string[] str)
        {
            SQLiteParameter[] pas = new SQLiteParameter[str.Length/ 2];
            for (int i = 0; i < str.Length / 2; i++)
            {
                pas[i] = new SQLiteParameter(string.Format("@{0}", str[2 * i]), str[2 * i + 1]);
            }
            return pas;
        }
    }
}

posted on 2009-09-02 11:07 sanmao 閱讀(202) 評論(0) 編輯收藏

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理

常用鏈接

留言簿(5)

隨筆分類

隨筆檔案

搜索

最新評論

1.?re: 解決方法:An error occurred on the server when processing the URL. Please contact the system administrator
太謝謝你了服務器搞了幾天了網上搜索一大堆加個端口就OK了郁悶！~
--謝謝你
2.?re: PowerDesigner使用教程|使用方法
評論內容較長,點擊標題查看
--RYJ
3.?re: PowerDesigner使用教程|使用方法
大愛樓主啊~
--RYJ
4.?re: 連續循環向上滾動代碼
恭喜快捷付一卡通張先生借款202522，成功打入卡中
--啥都吃
5.?re: jquery-1.5.2.min js下載
好
--啊啊啊
6.?re: 解決方法:An error occurred on the server when processing the URL. Please contact the system administrator
幫我解開
--段秀林
7.?企業班組長管理證書
查找證書
--朱培義
8.?re: Oracle 11g 下載|Oracle 11g 官網下載|Oracle 11g 官網下載帶登錄用戶和密碼
樓主你那賬號好像登不了
--學咖妃的菜鳥
9.?re: ORACLE 10g下載|ORACLE 10g下載地址|ORACLE 10g官網下載地址[未登錄]
感謝樓主現在oracle10G 實在不好找了感謝分享這么全的一文在手天下我有
--wj
10.?re: 解決方法:An error occurred on the server when processing the URL. Please contact the system administrator[未登錄]
ssss
--s
11.?re: jquery ui dialog|popup 彈出窗口層
單獨的
--單獨的
12.?re: jquery ui dialog|popup 彈出窗口層
出錯的vV熱情
--單獨的
13.?re: [導入]MyEclipse 8.5 M1注冊碼|MyEclipse 8.5 M2注冊碼
asdf
--潘坤
14.?re: PowerDesigner使用教程|使用方法[未登錄]
第二個畫圖的工具怎么點出來啊
--1
15.?re: 水晶報表的顯示報表數據[未登錄]
123456
--123
16.?re: PowerDesigner使用教程|使用方法
學的很好啊，謝謝樓主
--四海驕陽
17.?re: Ext.grid.GridPanel |屬性|方法|配置|詳細介紹
asdf
--asdf
18.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載
登錄不了啊
--Stevies
19.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載
謝謝！
--Stevies
20.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載
謝謝，有Linux的就更好了
--oracle
21.?re: Oracle 11g 下載|Oracle 11g 官網下載|Oracle 11g 官網下載帶登錄用戶和密碼[未登錄]
現在怎么不能下載了
--1
22.?re: PowerDesigner使用教程|使用方法
學習了~
--RYJ
23.?re: PowerDesigner使用教程|使用方法[未登錄]
@haha
好的，不錯
--test
24.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載[未登錄]
謝謝博主，謝謝各位
--java
25.?re: PowerDesigner使用教程|使用方法
謝謝樓主的分享，非常感謝
--kz
26.?re: PowerDesigner使用教程|使用方法
學習了
--rommr
27.?re: jquery ui dialog|popup 彈出窗口層[未登錄]
11
--1
28.?re: 留言框代碼
人發發是否飛灑發放發送法爾范薩芬
--安安
29.?re: PowerDesigner使用教程|使用方法
請問下樓主我用腳本反向生成model 怎么講腳本里面的comment在model里面也有（我用的是DB29.1）。
--anuous
30.?re: ORACLE 10g下載|ORACLE 10g下載地址|ORACLE 10g官網下載地址
樓主真是個好人
--zero_cool
31.?re: 在分析向此請求提供服務所需資源時出錯。請檢查下列特定分析錯誤詳細信息并適當地修改源文件[未登錄]
評論內容較長,點擊標題查看
--周周
32.?re: 清華it證書查詢網
結業證書
--嚴定美
33.?re: 獲取域名的正則表達式
www.baidu.com/music
--yj
34.?re: PowerDesigner使用教程|使用方法[未登錄]
very good
--...
35.?re: ORACLE 10g下載|ORACLE 10g下載地址|ORACLE 10g官網下載地址
太感謝分享個賬戶來下載軟件了。謝謝
--ChurKen
36.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載
謝謝博主了，超級感謝
--#r
37.?re: oracle 12c 下載|oracle 12c 官網下載帶用戶名密碼|oracle 12c for windows64下載[未登錄]
謝謝博主，賬號分享超級給力，也謝謝樓上各位沒有改密碼，讓大家都能用、、、
--葉
38.?re: q寵寶貝卸載|怎么卸載
太煩人了
--莜何
39.?re: Oracle 11g 下載|Oracle 11g 官網下載|Oracle 11g 官網下載帶登錄用戶和密碼
THANKS!
--666
40.?re: web打印控件|打印預覽[未登錄]
11111111111111111111111111111111111111
--111

閱讀排行榜

評論排行榜

主站蜘蛛池模板：汝南县| 金华市| 红桥区| 新宁县| 沙洋县| 桂东县| 湖南省| 沙田区| 南丰县| 客服| 蒙山县| 吴忠市| 封丘县| 南涧| 资中县| 中阳县| 玉林市| 巫山县| 秦安县| 佛学| 镇平县| 台山市| 秭归县| 阿鲁科尔沁旗| 封丘县| 图们市| 郑州市| 安福县| 颍上县| 昔阳县| 乌兰察布市| 汉寿县| 棋牌| 东平县| 正镶白旗| 安康市| 绥芬河市| 克拉玛依市| 小金县| 满洲里市| 尉氏县|

<ul id="oyae8"></ul>

<strike id="oyae8"></strike>