天天看點

C#操縱資料庫簡單記錄

OLEDB模式:

//需使用使用OleDbConnection,OleDbDataAdapter,OleDbCommandBuilder和DataSet

using System.Data;

using System.Data.OleDb;

        static void Main(string[] args)

        {

            try

            {

                OleDbConnection dbConn = new OleDbConnection();

                dbConn.ConnectionString = "Provider=sqloledb;Server=localhost;DATABASE=HotelDB;UID=sa;PWD=283918788;";

                dbConn.Open();

                OleDbDataAdapter dbAdap = new OleDbDataAdapter();       //聲明Adapter用以"連接配接"資料庫和DataSet

                String sqlCmdStr = "select * from Employees";

                dbAdap.SelectCommand = new OleDbCommand(sqlCmdStr, dbConn);   //填充資料來源

                DataSet ds = new DataSet();

                dbAdap.Fill(ds,"Employees");                                   //填充

                for (int i = 0; i < ds.Tables["Employees"].Rows.Count; i++)    //檢視ds結果集中的記錄

                {

                    Console.WriteLine(ds.Tables["Employees"].Rows[i][0].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][1].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][2].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][3].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][4].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][5].ToString());

                }

                Console.WriteLine("-----------------------------------------------------");

                for (int i = 0; i < ds.Tables["Employees"].Rows.Count; i++)

                {

                    Console.WriteLine(ds.Tables["Employees"].Rows[i][0].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][1].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][2].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][3].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][4].ToString()+" "+

                        ds.Tables["Employees"].Rows[i][5].ToString());

                }

                dbConn.Close();

            }

            catch(Exception e)

            {

                Console.WriteLine(e.Message);

            }

            Console.WriteLine("-------------------\nRunOver");

            Console.Read();

        }

SQLClient模式:

//需使用SqlConnection,SqlCommand,SqlDataReader

using System.Data;

using System.Data.SqlClient;

        static void Main(string[] args)

        {

            SqlConnection dbConn = new SqlConnection();

            try

            {

                dbConn.ConnectionString = "Server=localhost;DATABASE=HotelDB;UID=sa;PWD=283918788;";

                dbConn.Open();

                SqlCommand sqlCmd = new SqlCommand();

                sqlCmd.Connection = dbConn;

                String sqlCmdText = "select * from Employees";

                sqlCmd.CommandText = sqlCmdText;

                SqlDataReader dr = sqlCmd.ExecuteReader();

                Console.WriteLine("Connection OK!");

                Console.WriteLine("---------------------------------------");

                while (dr.Read())               //檢視ds結果集中的記錄

                {

                    Console.WriteLine(dr.GetInt32(0) + " " + dr.GetValue(1) + " " + dr.GetValue(2));

                }

                Console.WriteLine("---------------------------------------");

                dr.Close();

            }

            catch (Exception e)

            {

                Console.WriteLine(e.Message);

            }

            finally

            {

                if( dbConn.State == ConnectionState.Open )

                    dbConn.Close();

            }

            Console.WriteLine("Connection Close!");

            Console.Read();

        }