发一个SQLCE Helper类,(未验证)

川长思鸟来 2022-08-03 15:51 121阅读 0赞

using System;

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

namespace sqlce  
\{  
    class SqlCeHelper : IDisposable  
    \{  
        private SqlCeConnection connection;  
        private SqlCeCommand command;  
        private const string connectionString = "Data　Source=/MyDatabase\#1.sdf";

\#region　Open/Close  
        public void Open()  
        \{  
            try  
            \{  
                connection = new SqlCeConnection(connectionString);  
                command = connection.CreateCommand();  
                command.Connection = connection;  
                command.CommandType = CommandType.Text;

connection.Open();  
            \}  
            catch (DataException e)  
            \{  
                Console.WriteLine(e.Message);  
            \}  
        \}

public void Close()  
        \{  
            connection.Close();  
            connection.Dispose();  
        \}

public void Dispose()  
        \{  
            connection.Close();  
            connection.Dispose();  
            command.Dispose();  
        \}  
        \#endregion

\#region　Operatons  
        public SqlCeDataReader ExecuteReader(string sql)  
        \{  
            command.CommandText = sql;  
            SqlCeDataReader reader = null;  
            try  
            \{  
                reader = command.ExecuteReader();  
            \}  
            catch (DataException e)  
            \{  
                Console.WriteLine(e.Message);  
            \}  
            return reader;  
        \}

public DataSet ExecuteDataSet(string sql)  
        \{  
            command.CommandText = sql;  
            SqlCeDataAdapter adapter = new SqlCeDataAdapter(command);  
            DataSet ds = new DataSet(); ;

try  
            \{  
                adapter.Fill(ds);  
            \}  
            catch (DataException e)  
            \{  
                Console.WriteLine(e.Message);  
            \}  
            return ds;  
        \}

public int ExecuteNonQuery(string sql)  
        \{  
            command.CommandText = sql;  
            int result = -1;

try  
            \{  
                result = command.ExecuteNonQuery();  
            \}  
            catch (DataException e)  
            \{  
                Console.WriteLine(e.Message);

\}  
            return result;  
        \}

public object ExecuteScalar(string sql)  
        \{  
            command.CommandText = sql;  
            object o = null;  
            try  
            \{  
                o = command.ExecuteScalar();  
            \}  
            catch (DataException e)  
            \{  
                Console.WriteLine(e.Message);  
            \}  
            return o;  
        \}  
        \#endregion

\#region　Transaction  
        public void BeginTransaction()  
        \{  
            command.Transaction = connection.BeginTransaction();  
        \}

public void CommitTransaction()  
        \{  
            command.Transaction.Commit();  
        \}

public void RollbackTransaction()  
        \{  
            command.Transaction.Rollback();  
        \}  
        \#endregion  
    \}  
\}