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

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);

如连接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();

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）连接之后，我可以有多种方式取得数据