Perl/C#连接Oracle/SQL Server
连接数据库是一个很常见也很必须的操作。先将我用到的总结一下。 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)连接之后,我可以有多种方式取得数据 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |