Get column average


   


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

public class DatabaseInfo {    
 public static void Main () { 
   String connect = "Provider=Microsoft.JET.OLEDB.4.0;data source=.Employee.mdb";
   OleDbConnection con = new OleDbConnection(connect);
   con.Open();  
   Console.WriteLine("Made the connection to the database");

   OleDbCommand command = con.CreateCommand();
   command.CommandText = "SELECT AVG(Salary) FROM Employee";
   Console.WriteLine("Average of salary: {0:C}",(decimal)command.ExecuteScalar());


   con.Close();
 }
}
 
           
          


Execute aggregate function: sum


   

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

public class DatabaseInfo {    
 public static void Main () { 
   String connect = "Provider=Microsoft.JET.OLEDB.4.0;data source=.Employee.mdb";
   OleDbConnection con = new OleDbConnection(connect);
   con.Open();  
   Console.WriteLine("Made the connection to the database");

   OleDbCommand command = con.CreateCommand();
   command.CommandText ="SELECT SUM(salary) FROM Employee";
   Console.WriteLine("Sum of salary: {0:C}",(decimal)command.ExecuteScalar());


   con.Close();
 }
}
 

           
          


OleDbConnection: ConnectionTimeout

   
 

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

class MainClass {
    public static void Main() {
        using (OleDbConnection con = new OleDbConnection()) {
            con.ConnectionString = "Provider=SQLOLEDB;" +     
                @"Data Source=.sqlexpress;" + 
                "Initial Catalog=Northwind;" + 
                "Integrated Security=SSPI";    

            con.Open();

            if (con.State == ConnectionState.Open) {
                Console.WriteLine("  Timeout = " + con.ConnectionTimeout);
            } else {
                Console.WriteLine("OleDbConnection failed to open.");
                Console.WriteLine("  Connection State = " + con.State);
            }
        }
    }
}

    


how to execute a TableDirect command

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

class ExecuteTableDirect
{
public static void Main()
{
OleDbConnection myOleDbConnection =new OleDbConnection(“provider=sqloledb;server=(local)SQLEXPRESS;database=MyDatabase;Integrated Security=SSPI”);
OleDbCommand myOleDbCommand = myOleDbConnection.CreateCommand();

myOleDbCommand.CommandType = CommandType.TableDirect;

myOleDbCommand.CommandText = “Employee”;

myOleDbConnection.Open();

OleDbDataReader myOleDbDataReader = myOleDbCommand.ExecuteReader();

for (int count = 1; count <= 2; count++) { myOleDbDataReader.Read(); Console.WriteLine("myOleDbDataReader[" ID"] = " + myOleDbDataReader["ID"]); Console.WriteLine("myOleDbDataReader[" FirstName"] = " + myOleDbDataReader["FirstName"]); Console.WriteLine("myOleDbDataReader[" LastName"] = " + myOleDbDataReader["LastName"]); } myOleDbDataReader.Close(); myOleDbConnection.Close(); } } [/csharp]

Read query result from OdbcCommand

using System;
using System.Data;
using System.Data.Odbc;

class CommandOdbcExample{

static void Main() {
OdbcConnection thisConnection = new OdbcConnection(“DRIVER={MySQL ODBC 3.51 Driver};SERVER=localhost;DATABASE=test;UID=root;PASSWORD=;”);

OdbcCommand nonqueryCommand = thisConnection.CreateCommand();

try {
thisConnection.Open();

nonqueryCommand.CommandText = “CREATE TABLE MyTable (MyName VARCHAR (30), MyNumber integer)”;
Console.WriteLine(nonqueryCommand.CommandText);
nonqueryCommand.ExecuteNonQuery();

nonqueryCommand.CommandText = “INSERT INTO MyTable VALUES (?, ?)”;

nonqueryCommand.Parameters.Add(“@MyName”, OdbcType.VarChar, 30);
nonqueryCommand.Parameters.Add(“@MyNumber”, OdbcType.Int);

string[] names = { “A”, “B”, “C”, “D” } ;
int i;
for (i=1; i<=4; i++){ nonqueryCommand.Parameters["@MyName"].Value = names[i-1]; nonqueryCommand.Parameters["@MyNumber"].Value = i; Console.WriteLine(nonqueryCommand.CommandText); Console.WriteLine("Number of Rows Affected is: {0}", nonqueryCommand.ExecuteNonQuery()); } nonqueryCommand.CommandText = "SELECT MyName, MyNumber FROM MyTable"; OdbcDataReader thisReader = nonqueryCommand.ExecuteReader(); while (thisReader.Read()) { Console.WriteLine("Name and Number: {0} {1}", thisReader.GetValue(0), thisReader.GetValue(1)); } thisReader.Close(); nonqueryCommand.CommandText = "DROP TABLE MyTable"; nonqueryCommand.ExecuteNonQuery(); } catch (OdbcException ex) { Console.WriteLine(ex.ToString()); } finally { thisConnection.Close(); Console.WriteLine("Connection Closed."); } } } [/csharp]

Pass parameters to OdbcCommand

using System;
using System.Data;
using System.Data.Odbc;

class CommandOdbcExample{

static void Main() {
OdbcConnection thisConnection = new OdbcConnection(“DRIVER={MySQL ODBC 3.51 Driver};SERVER=localhost;DATABASE=test;UID=root;PASSWORD=;”);

OdbcCommand nonqueryCommand = thisConnection.CreateCommand();

try {
thisConnection.Open();

nonqueryCommand.CommandText = “CREATE TABLE MyTable (MyName VARCHAR (30), MyNumber integer)”;
Console.WriteLine(nonqueryCommand.CommandText);
nonqueryCommand.ExecuteNonQuery();

nonqueryCommand.CommandText = “INSERT INTO MyTable VALUES (?, ?)”;

nonqueryCommand.Parameters.Add(“@MyName”, OdbcType.VarChar, 30);
nonqueryCommand.Parameters.Add(“@MyNumber”, OdbcType.Int);

// nonqueryCommand.Prepare();
string[] names = { “A”, “B”, “C”, “D” } ;
int i;
for (i=1; i<=4; i++){ nonqueryCommand.Parameters["@MyName"].Value = names[i-1]; nonqueryCommand.Parameters["@MyNumber"].Value = i; Console.WriteLine(nonqueryCommand.CommandText); Console.WriteLine("Number of Rows Affected is: {0}", nonqueryCommand.ExecuteNonQuery()); } nonqueryCommand.CommandText = "SELECT MyName, MyNumber FROM MyTable"; OdbcDataReader thisReader = nonqueryCommand.ExecuteReader(); while (thisReader.Read()) { Console.WriteLine("Name and Number: {0} {1}", thisReader.GetValue(0), thisReader.GetValue(1)); } thisReader.Close(); nonqueryCommand.CommandText = "DROP TABLE MyTable"; nonqueryCommand.ExecuteNonQuery(); } catch (OdbcException ex) { Console.WriteLine(ex.ToString()); } finally { thisConnection.Close(); Console.WriteLine("Connection Closed."); } } } [/csharp]

Create database through OdbcCommand

using System;
using System.Data;
using System.Data.Odbc;

class CommandOdbcExample{

static void Main() {
OdbcConnection thisConnection = new OdbcConnection(“DRIVER={MySQL ODBC 3.51 Driver};SERVER=localhost;DATABASE=test;UID=root;PASSWORD=;”);

OdbcCommand nonqueryCommand = thisConnection.CreateCommand();

try {
thisConnection.Open();

nonqueryCommand.CommandText = “CREATE TABLE MyTable (MyName VARCHAR (30), MyNumber integer)”;
Console.WriteLine(nonqueryCommand.CommandText);
nonqueryCommand.ExecuteNonQuery();

nonqueryCommand.CommandText = “INSERT INTO MyTable VALUES (?, ?)”;

nonqueryCommand.Parameters.Add(“@MyName”, OdbcType.VarChar, 30);
nonqueryCommand.Parameters.Add(“@MyNumber”, OdbcType.Int);

// nonqueryCommand.Prepare();
string[] names = { “A”, “B”, “C”, “D” } ;
int i;
for (i=1; i<=4; i++){ nonqueryCommand.Parameters["@MyName"].Value = names[i-1]; nonqueryCommand.Parameters["@MyNumber"].Value = i; Console.WriteLine(nonqueryCommand.CommandText); Console.WriteLine("Number of Rows Affected is: {0}", nonqueryCommand.ExecuteNonQuery()); } nonqueryCommand.CommandText = "SELECT MyName, MyNumber FROM MyTable"; OdbcDataReader thisReader = nonqueryCommand.ExecuteReader(); while (thisReader.Read()) { Console.WriteLine("Name and Number: {0} {1}", thisReader.GetValue(0), thisReader.GetValue(1)); } thisReader.Close(); nonqueryCommand.CommandText = "DROP TABLE MyTable"; nonqueryCommand.ExecuteNonQuery(); } catch (OdbcException ex) { Console.WriteLine(ex.ToString()); } finally { thisConnection.Close(); Console.WriteLine("Connection Closed."); } } } [/csharp]