Perl/C#连接Oracle/SQL Server和简单操作

水电工888

　　连接数据库是一个很常见也很必须的操作。先将我用到的总结一下。
　　

　　1. Perl 连接数据库
　　Perl 连接数据库的思路都是：
　　1）使用DBI模块； 2）创建数据库连接句柄dbh； 3）利用dbh创建语句句柄sth； 4）利用sth执行sql语句； 5）利用sth处理数据。
　　连接Oracle：



    my $dbh=DBI->connect("DBI:Oracle:host=$hostname;sid=$sid",$username,$passwd);  
### deal with multi return value  
my $sql=qq(select uid_der from wbphish_usr_der);  
$sth->execute();  
my $sth=$dbh->prepare($sql);  
$sth->execute() or die;  
my @uid;  
while(my @row=$sth->fetchrow_array)  
{   push @uid,$row[0];}  
### deal with single return value  
my $sql="SELECT max(DEMO) FROM phishing"  
$sth->execute();  
my $sth=$dbh->prepare($sql);  
$sth->execute() or die;  
my $id=$dbh->selectrow_array($sql);  
　　其中host是数据库server的ip地址，sid为连接的数据库。
　　连接SQL Server：



    my $dbh = DBI->connect("dbi:ODBC:driver={SQL Server};Server=127.0.0.1;Database=$dbs;UID=$uid;PWD=$pwd");  
my $sth = $dbh->prepare($sql);  
$sth->execute();  
　　其中Server是server的ip地址，这里是local地址，Database为连接的数据库。
　　

　　2. C# 连接数据库
　　C# 连接数据库的思路是：
　　1）连接给定参数建立连接对象； 2）利用连接对象建立SQL语句对象； 3）利用SQL语句对象执行并处理数据。
　　连接SQL Server：



    namespace ConsoleApplication1  
{  
class Program  
{  
static void Main(string[] args)  
{  
/*Create Connection*/  
//connection-string(Local Server:127.0.0.1) & SQL-string define  
string conString = "Server=(local); database=test; uid=sa; password=123456";  
string sqlString = "select top 10 " + metricName + ",MetricTime from Metric where MetricTime > @metricTime order by MetricTime";  
//create a connection  
SqlConnection con = new SqlConnection(conString);  
con.Open();  
/*First way*/  
//create a SQL command within connection, use SqlDataReader(light-level) to read retrieved data  
SqlCommand cmd = new SqlCommand(sqlString, con);  
SqlParameter[] sps = new SqlParameter[] { new SqlParameter("@metricTime", metricTime) };  //Use SqlParameter to avoid "SQL injection".  
                cmd.Parameters.AddRange(sps);  
SqlDataReader sdr = cmd.ExecuteReader();  
//Read data from DataReader  
while (sdr.Read())  
Console.WriteLine((double)sdr[metricName]);  
con.Close();  
cmd.Dispose();  

/*Second way*/  
//create a SQL command within connection, use SqlDataAdapter to read retrieved data  
SqlDataAdapter sqlDad = new SqlDataAdapter(sqlString, sqlCon);              
SqlParameter sqlPar = new SqlParameter("@metricTime", metricTime);   //Use SqlParameter to avoid "SQL injection".  
                sqlDad.SelectCommand.Parameters.Add(sqlPar);  
DataSet metricDS = new DataSet("MetricDS");  
sqlDad.Fill(metricDS, "Metric");            
//Read data from DataSet  
foreach (DataRow row in dst.Tables["Monitor"].Rows)  
Console.WriteLine(row["ID"] + "\t" + row["RecordTime"] + "\t" + row["VideoView"] + "\t" + row["Fluency"]);  
sqlCon.Close();  
}  
}  
}  
　　其中连接字串中Server是数据库server的ip地址，database是指定连接的数据库。
　　代码首先建立连接，然后分别以SqlDataReader和SqlDataAdapter两种方式处理了数据，且利用了SqlParameter来避免SQL injection。
　　

　　
　　
以上看来，连接数据库的时候，你得告诉程序：
　　1）我去连接哪个数据库server呀，2）我连到server了，我去连哪个数据库呀？不然我的sql语句找不到table么。 3）连接之后，我可以有多种方式取得数据