public void CreateSqlConnection()
{ 
SqlConnection myConnection = new SqlConnection();
myConnection.ConnectionString="Persist  Security Info=False;
Integrated Security=SSPI;database=northwind;
server=mySQLServer;Connect Timeout=30";
myConnection.Open()}



public void InsertRow(string myConnectionString)
{
// If the connection string is null, use a default.
if(myConnectionString = = "")
{
myConnectionString ="Provider=SQLOLEDB;Data Source=localhost;
Initial Catalog=Northwind;"+"Integrated Security=SSPI;";
}
OleDbConnection myConnection =new OleDbConnection(myConnectionString);
string myInsertQuery = "INSERT INTO Customers (CustomerID, CompanyName) Values('NWIND', 'Northwind Traders')";
OleDbCommand myCommand = new OleDbCommand(myInsertQuery);
myCommand.Connection = myConnection;
myConnection.Open();
myCommand.ExecuteNonQuery();
myCommand.Connection.Close();
}


public void InsertRow(string myConnection)
{
// If the connection string is null, use a default.
if(myConnection == "")
{
myConnection="DRIVER={SQL Server};SERVER=MyServer;
Trusted_connection=yes;DATABASE=northwind;";
}
OdbcConnection myConn = new OdbcConnection(myConnection);
string myInsertQuery = "INSERT INTO Customers (CustomerID, CompanyName) Values('NWIND', 'Northwind Traders')";
OdbcCommand myOdbcCommand = new OdbcCommand(myInsertQuery);
myOdbcCommand.Connection = myConn;
myConn.Open();
myOdbcCommand.ExecuteNonQuery();
myOdbcCommand.Connection.Close();
}



using System;
using System.Web;
using System.Web.UI;
using System.Web.UI.HtmlControls;
using System.Web.UI.WebControls;
using System.Data;
using System.Data.OracleClient;
public class pic2:Page {
public Label message;
public void Page_Load(Object sender,EventArgs e)
{
//ַ
string connstring="Data Source=eims;user=zbmis;
password=zbmis;";
//ʵOracleConnection
OracleConnection conn=new OracleConnection(connstring);
try
{
conn.Open();
//ʵOracleCommand
OracleCommand cmd=conn.CreateCommand();
cmd.CommandText="select * from zbmis.OracleTypesTable";
OracleDataReader oracledatareader1=cmd.ExecuteReader();
//ȡ
 while (oracledatareader1.Read()) {
//ȡʾһеһе
OracleString oraclestring1=oracledatareader1.GetOracleString(0);
Response.Write("OracleString " +oraclestring1.ToString());
//ȡʾһеڶе
OracleNumber oraclenumber1 =
oracledatareader1.GetOracleNumber(1);
Response.Write("OracleNumber "+oraclenumber1.ToString());
//ȡʾһее
OracleDateTime oracledatetime1
=oracledatareader1.GetOracleDateTime(2);
Response.Write("OracleDateTime " +oracledatetime1.ToString());
//ȡʾһее
OracleBinary oraclebinary1
=oracledatareader1.GetOracleBinary(3);
if(oraclebinary1.IsNull==false)
{
foreach(byte b in oraclebinary1.Value)
{
Response.Write("byte " +b.ToString());
}
}
}
//ͷԴ
oracledatareader1.Close();
}
catch(Exception ee)
{
//쳣
message.Text=ee.Message;
}
finally
{
//ر
conn.Close();
}
}
}


Using System;
using System.Data;
using System.Data.SqlClient;
public class myDataAccess{
public static void Main(){
SqlConnection conn = new SqlConnection("Server=localhost;
Database=Northwind;User ID=sa;PWD=sa");
SqlCommand cmd = new SqlCommand("update [Orders] set
      [OrderDate]='2004-9-1' where OrderID]=10248",conn);
try{
conn.Open();
int I = cmd.ExecuteNonQuery();
Console.WriteLine(i.ToString() + " rows affected by UPDATE");
cmd.CommandText = "select * from [Orders]";
i = cmd.ExecuteNonQuery();
Console.WriteLine(i.ToString() + " rows affected by SELECT");
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}




using System;
using System.Data;
using System.Data.SqlClient;
public class myDataAccess{
public static void Main(){
SqlConnection conn = new SqlConnection("Server=localhost;
Database=Northwind;Uer ID=sa;PWD=sa");
SqlCommand cmd = new SqlCommand("select top 20 * from [Orders]",
conn);
SqlDataReader reader; //IDataReader reader;
try{
conn.Open();
reader = cmd.ExecuteReader();
while(reader.Read()){
Console.WriteLine(reader[0].ToString());
}
reader.Close();
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}



using System;
using System.Data;
using System.Data.SqlClient;
public class myDataAccess{
public static void Main(){
SqlConnection conn = new SqlConnection("Server=localhost;
Database=Northwind;Uer ID=sa;PWD=sa");
SqlCommand cmd = new SqlCommand("select count(*) from [Orders]",conn);
try{
conn.Open();
int i = (int)cmd.ExecuteScalar();
Console.WriteLine("record num : " + i.ToString());
cmd.CommandText = "select cast(avg([Freight]) as int) from [Orders]";
int avg = (int)cmd.ExecuteScalar();
Console.WriteLine("avg : " + avg.ToString());
cmd.CommandText = "select avg([Freight]) from [Orders]";
avg = (int)cmd.ExecuteScalar(); //쳣
Console.WriteLine("avg : " + avg.ToString());
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}



using System;
using System.Data.SqlClient;
using System.Data;
using System.Xml;

namespace XMLAUTO
{
/// <summary>
/// Class1 ժҪ˵
/// </summary>
class Class1
{
/// <summary>
/// Ӧóڵ㡣
/// </summary>
[STAThread]
static void Main(string[] args)
{
//
// TODO: ڴ˴ӴӦó
//
string source = "workstation id=localhost;
Integrated Security=SSPI;database=NorthWind";
string select = "SELECT ContactName,CompanyName " +
"FROM Customers FOR XML AUTO";
SqlConnection conn = new SqlConnection(source);
conn.Open();
SqlCommand cmd = new SqlCommand(select, conn);
XmlReader xr = cmd.ExecuteXmlReader();
while(xr.Read())
{
Console.WriteLine(xr.ReadOuterXml());
}
conn.Close();
}
}
}



using System;
using System.Data;
using System.Data.SqlClient;
public class myDataAccess{
public static void Main(String[] args){
SqlConnection conn =
new SqlConnection("Server=localhost;Database=Northwind;UID=sa;PWD=sa");
SqlCommand cmd = new SqlCommand("select * from [Orders] where 
[OrderID]=@oid",conn);
SqlDataReader reader;
try{
int param = Convert.ToInt32(args[0]);
cmd.Parameters.Add("@oid",param);  //ʹ
cmd.Parameters[0].Direction = ParameterDirection.Input;
conn.Open();
reader = cmd.ExecuteReader();
while(reader.Read()){
Console.WriteLine(reader[0].ToString());
}
reader.Close();
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}



using System;
using System.Data;
using System.Data.OleDb;
public class myDataAccess{
public static void Main(String[] args){
OleDbConnection conn = new OleDbConnection("Provider=SQLOLEDB;Server=loca
host;Database=Northwind;User ID=sa;PWD=sa");
OleDbCommand cmd = new OleDbCommand("select * from [Orders] where [Orde
ID]=? or [EmployeeID]=?",conn);
OleDbDataReader reader;
try{
int param1 = Convert.ToInt32(args[0]);
int param2 = Convert.ToInt32(args[1]);
cmd.Parameters.Add("aaa",param1);
cmd.Parameters.Add("bbb",param2);
//Ҫ֣ǺͲѯеĲ޹
cmd.Parameters[0].Direction = ParameterDirection.Input;
cmd.Parameters[1].Direction = ParameterDirection.Input;
conn.Open();
reader = cmd.ExecuteReader();
while(reader.Read()){
Console.WriteLine(reader[0].ToString());
}
reader.Close();
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}



//洢
CREATE procedure myProTest (
@orderID as int,
@elyTitle as varchar(50) output
)
As
select @elyTitle=ely.Title from [Orders] o join [Employees] ely on ely.EmployeeID=o.mployeeID where o.OrderID=@orderID
select * from [Orders] where OrderID=@orderID
return 1
//
using System;
using System.Data;
using System.Data.SqlClient;
public class myDataAccess{
public static void Main(){
SqlConnection conn =
new SqlConnection("Server=localhost;Database=Northwind;UID=sa;PWD=sa");
SqlCommand cmd = new SqlCommand("myProTest",conn);
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("@orderID",10252);
cmd.Parameters.Add("@elyTitle",SqlDbType.VarChar,50);
cmd.Parameters.Add("@return",SqlDbType.Int);
cmd.Parameters[0].Direction = ParameterDirection.Input;
cmd.Parameters[1].Direction = ParameterDirection.Output;
cmd.Parameters[2].Direction = ParameterDirection.ReturnValue;
SqlDataReader reader;
try{
conn.Open();
Console.WriteLine("execute reader...");
reader = cmd.ExecuteReader();
Console.WriteLine("@orderID = {0}",cmd.Parameters[0].Value);
Console.WriteLine("@elyTitle = {0}",cmd.Parameters[1].Value);
Console.WriteLine("Return = {0}",cmd.Parameters[2].Value);
Console.WriteLine("reader close...");
reader.Close();
Console.WriteLine("@orderID = {0}",cmd.Parameters[0].Value);
Console.WriteLine("@elyTitle = {0}",cmd.Parameters[1].Value);
Console.WriteLine("Return = {0}",cmd.Parameters[2].Value);
Console.WriteLine("execute none query...");
cmd.ExecuteNonQuery();
Console.WriteLine("@orderID = {0}",cmd.Parameters[0].Value);
Console.WriteLine("@elyTitle = {0}",cmd.Parameters[1].Value);
Console.WriteLine("Return = {0}",cmd.Parameters[2].Value);
}
catch(Exception ex){
Console.WriteLine(ex.Message);
}
finally{
conn.Close();
}
}
}



using System;
using System.Data.OleDb;
using System.Data;

namespace OlDbRead
{
/// <summary>
/// Class1 ժҪ˵
/// </summary>
class Class1
{
/// <summary>
/// Ӧóڵ㡣
/// </summary>
[STAThread]
static void Main(string[] args)
{
//
// TODO: ڴ˴ӴӦó
//
string source = "Provider=SQLOLEDB;" +
"server=localhost;" +
"uid = sa; pwd=;"+
"database = northwind";
string select = "SELECT ContactName,CompanyName FROM Customers";
OleDbConnection conn = new OleDbConnection(source);
conn.Open();
OleDbCommand cmd = new OleDbCommand(select, conn);
OleDbDataReader aReader = cmd.ExecuteReader();
while(aReader.Read())
{
Console.WriteLine("'{0}' from {1}", aReader.GetString(0),
aReader.GetString(1));
}
aReader.Close();
conn.Close();
}
}
}



using System;
using System.Data;
using System.Data.SqlClient;

namespace ConsoleApplication1
{
	class Class1
	{
		/// <summary>
		/// Ӧóڵ㡣
		/// </summary>
		[STAThread]
		static void Main(string[] args)
		{
			//
			// TODO: ڴ˴ӴӦó
			//
			string connstr = "server = .;Integrated Security=SSPI; database = Northwind;";
			SqlConnection conn = new SqlConnection(connstr);
			string SQL = "select companyname,contactname from customers; select firstname,lastname from employees";
            SqlCommand sqlComm = new SqlCommand(SQL,conn);
			try
			{
				conn.Open();
				SqlDataReader dr = sqlComm.ExecuteReader();
				do
				{
					Console.WriteLine("{0}\t\t{1}",dr.GetName(0), dr.GetName(1));
					while(dr.Read())
					{
						Console.WriteLine("{0}\t\t{1}",dr.GetSqlString(0), dr.GetSqlString(1));
					}
				}
				while(dr.NextResult());
				dr.Close();
				conn.Close();
			}
			catch(Exception e)
			{
			    Console.WriteLine(e.Message); 
			}
			finally
			{
			 conn.Close();
			 Console.ReadLine();
				
			}
		}
	}
}





using System;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Windows.Forms;

public class DataGridSample:Form{
DataSet ds;
DataGrid myGrid;

static void Main(){
Application.Run(new DataGridSample());
}

public DataGridSample(){
InitializeComponent();
}

void InitializeComponent(){
this.ClientSize = new System.Drawing.Size(550, 450);
myGrid = new DataGrid();
myGrid.Location = new Point (10,10);
myGrid.Size = new Size(500, 400);
myGrid.CaptionText = "Microsoft .NET DataGrid";
this.Text = "C# Grid Example";
this.Controls.Add(myGrid);
ConnectToData();
myGrid.SetDataBinding(ds, "Suppliers");
}
void ConnectToData(){
// Create the ConnectionString and create a SqlConnection
// Change the data source value to the name of your computer

string cString = "Persist Security Info=False;Integrated Security=SSPI;
database=northwind;server=mySQLServer";
SqlConnection myConnection = new SqlConnection(cString);
// Create a SqlDataAdapter
SqlDataAdapter myAdapter = new SqlDataAdapter();
myAdapter.TableMappings.Add("Table", "Suppliers");
myConnection.Open();
SqlCommand myCommand = new SqlCommand("SELECT * FROM Suppliers",
myConnection);
myCommand.CommandType = CommandType.Text;
myAdapter.SelectCommand = myCommand;
Console.WriteLine("The connection is open");
ds = new DataSet("Customers");
myAdapter.Fill(ds);
// Create a second Adapter and Command
SqlDataAdapter adpProducts = new SqlDataAdapter();
adpProducts.TableMappings.Add("Table", "Products");
SqlCommand cmdProducts = new SqlCommand("SELECT * FROM Products",
myConnection);
adpProducts.SelectCommand = cmdProducts;
adpProducts.Fill(ds);
myConnection.Close();
Console.WriteLine("The connection is closed.");
System.Data.DataRelation dr;
System.Data.DataColumn dc1;
System.Data.DataColumn dc2;
// Get the parent and child columns of the two tables
dc1 = ds.Tables["Suppliers"].Columns["SupplierID"];
dc2 = ds.Tables["Products"].Columns["SupplierID"];
dr = new System.Data.DataRelation("suppliers2products", dc1, dc2);
ds.Relations.Add(dr);
}
}





