using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.OracleClient;
using System.Data;
using System.Windows.Forms;
using System.Data.OleDb;
namespace WindowsFormsApplication1
{
class OracleServer
{
private OleDbConnection cnn;
private OleDbCommand cmd;
private DataSet ds;
private DataTable dt;
private OleDbDataAdapter oda;
public void initSql()
{
cnn = new OleDbConnection("Provider=MSDAORA;Data Source=orcl;User ID=system;Password=123456");
try
{
cnn.Open();
}
catch
{
MessageBox.Show("数据库连接失败", "消息");
}
}
public int readSql(string sql)
{
ds = new DataSet();
oda = new OleDbDataAdapter(sql, cnn);
oda.Fill(ds);
return ds.Tables[0].Rows.Count;
}
public string readSqlString(string sql)
{
int n = 0;
ds = new DataSet();
oda = new OleDbDataAdapter();
oda.SelectCommand = new OleDbCommand(sql, cnn);
oda.Fill(ds);
cmd = new OleDbCommand(sql, cnn);
OleDbDataReader dr = cmd.ExecuteReader();
while (dr.Read())
{
n += 1;
return dr.GetValue(0).ToString(); ;
}
return "";
}
public void writeSql(string sql)
{
cmd = new OleDbCommand(sql, cnn);
cmd.ExecuteNonQuery();
}
public void closeSql()
{
cnn.Close();
}
}
}
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.OracleClient;
using System.Data;
using System.Windows.Forms;
using System.Data.OleDb;
namespace WindowsFormsApplication1
{
class OracleServer
{
private OleDbConnection cnn;
private OleDbCommand cmd;
private DataSet ds;
private DataTable dt;
private OleDbDataAdapter oda;
public void initSql()
{
cnn = new OleDbConnection("Provider=MSDAORA;Data Source=orcl;User ID=system;Password=123456");
try
{
cnn.Open();
}
catch
{
MessageBox.Show("数据库连接失败", "消息");
}
}
public int readSql(string sql)
{
ds = new DataSet();
oda = new OleDbDataAdapter(sql, cnn);
oda.Fill(ds);
return ds.Tables[0].Rows.Count;
}
public string readSqlString(string sql)
{
int n = 0;
ds = new DataSet();
oda = new OleDbDataAdapter();
oda.SelectCommand = new OleDbCommand(sql, cnn);
oda.Fill(ds);
cmd = new OleDbCommand(sql, cnn);
OleDbDataReader dr = cmd.ExecuteReader();
while (dr.Read())
{
n += 1;
return dr.GetValue(0).ToString(); ;
}
return "";
}
public void writeSql(string sql)
{
cmd = new OleDbCommand(sql, cnn);
cmd.ExecuteNonQuery();
}
public void closeSql()
{
cnn.Close();
}
}
}