可以使用mysql推出的mysqlconnector/net組件,該組件是mysql為ado.net訪問mysql數(shù)據(jù)庫設(shè)計(jì)的.net專用訪問組件,完成該組件后,需要在項(xiàng)目中引用這個(gè)組件,之后在程序中引用命名空間mysql.data.mysqlclient,即可開始進(jìn)行連接mysql數(shù)據(jù)庫的操作了,示例如下:
成都創(chuàng)新互聯(lián)成都企業(yè)網(wǎng)站建設(shè)服務(wù),提供成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作網(wǎng)站開發(fā),網(wǎng)站定制,建網(wǎng)站,網(wǎng)站搭建,網(wǎng)站設(shè)計(jì),響應(yīng)式網(wǎng)站,網(wǎng)頁設(shè)計(jì)師打造企業(yè)風(fēng)格網(wǎng)站,提供周到的售前咨詢和貼心的售后服務(wù)。歡迎咨詢做網(wǎng)站需要多少錢:13518219792
protected
voidmysqlcon()
{
//數(shù)據(jù)庫連接字符串跟連接sqlserver沒有區(qū)別
string
constr
=
"server=localhost;userid=root;password=root;database=test";
//下面使用mysql
connector/net提供的專用對(duì)象
mysqlconnection
mycon
=
new
mysqlconnection(constr);
mycon.open();
mysqlcommandmycmd
=
new
mysqlcommand("select
*
from
users",
mycon);
mysqldatareader
myreader
=
mycmd.executereader();
while
(myreader.read())
{
if
(myreader.hasrows)
{
messagebox.show(myreader.getstring("email")
);
}
}
myreader.close();
mycon.close();
前提條件
您需要在您RDS for MySQL所在的云賬號(hào)下開通阿里云數(shù)據(jù)傳輸服務(wù)。并 點(diǎn)擊此處
下載dts-ads-writer插件到您的一臺(tái)服務(wù)器上并解壓(需要該服務(wù)器可以訪問互聯(lián)網(wǎng),建議使用阿里云ECS以最大限度保障可用性)。服務(wù)器上需要有Java
6或以上的運(yùn)行環(huán)境(JRE/JDK)。
操作步驟
1. 在分析型數(shù)據(jù)庫上創(chuàng)建目標(biāo)表,數(shù)據(jù)更新類型為實(shí)時(shí)寫入,字段名稱和MySQL中的建議均相同;
2. 在阿里云數(shù)據(jù)傳輸?shù)目刂婆_(tái)上創(chuàng)建數(shù)據(jù)訂閱通道,并記錄這個(gè)通道的ID;
(見: ),
3. 配置dts-ads-writer/app.conf文件,配置方式如下:
所有配置均保存在app.conf中,運(yùn)行前請(qǐng)保證配置正確;修改配置后,請(qǐng)重啟writer
基本配置:
{
"dtsAccessId":?"",??//?擁有數(shù)據(jù)訂閱通道的云賬號(hào)的accessId,?必須配置
"dtsAccessKey":?"",?//?擁有數(shù)據(jù)訂閱通道的云賬號(hào)的accessKey,?必須配置
"dtsTunnelId":?"",??//?數(shù)據(jù)訂閱通道的id,?必須配置;?注意是id,不是通道名稱
"adsUserName":?"",??//?訪問您的分析型數(shù)據(jù)庫的用戶名(accessId),?必須配置
"adsPassword":?"",??//?訪問您的分析型數(shù)據(jù)庫的密碼(accessKey),?必須配置
"adsJdbcUrl":?"",???//?訪問分析型數(shù)據(jù)庫的jdbc連接串,?必須配置(格式j(luò)dbc:mysql://ip:port/dbname)
"tables":?[
{
"source":?{
"primaryKeys":?[""]?//?主鍵定義,?必須配置;?注意RDS和分析型數(shù)據(jù)庫中的主鍵定義必須一致
"db":?"",?????//?源頭RDS的db名稱,?必須配置
"table":?"",????//?源頭RDS的table名稱,?必須配置
"skipColumns":?["col1"]???//?可選,若在此配置了RDS表某列名,則該列不會(huì)同步
},
"target":?{????????????
"table":?""?//?分析型數(shù)據(jù)庫表的table名稱,?必須配置
},
"columnMapping":?{
"":?""??//?rds表和ads表的列對(duì)應(yīng)關(guān)系:key為rds的列名,?value為分析型數(shù)據(jù)庫的列名,選填,不填則按照列名一一對(duì)應(yīng)
}?
}
]
}
tables節(jié)點(diǎn)的配置示例,?
表示rds_db庫下的rds_table表對(duì)應(yīng)ads_table表,并且rds_table表的col1列對(duì)應(yīng)ads_table表的col1_ads列,
rds_table表的col2列對(duì)應(yīng)ads_table表的col2_ads列
"tables":?[
{
"source":?{
"primaryKeys":?[
"col1",
"col2"
],
"db":?"rds_db",
"table":?"rds_table"
},
"target":?{
"table":?"ads_table"
},
"columnMapping":?{
"col1":?"col1_ads",
"col2":?"col2_ads"
}
}
]
注意事項(xiàng):
1)RDS for MySQL表和分析型數(shù)據(jù)庫中表的主鍵定義必須完全一致;如果不一致會(huì)出現(xiàn)數(shù)據(jù)不一致問題。如果需要調(diào)整RDS/分析型數(shù)據(jù)庫表的主鍵,建議先停止writer進(jìn)程;
2)一個(gè)插件進(jìn)程中分析型數(shù)據(jù)庫db只能是一個(gè),由adsJdbcUrl指定;
3)一個(gè)插件進(jìn)程只能對(duì)應(yīng)一個(gè)數(shù)據(jù)訂閱通道;如果更新通道中的訂閱對(duì)象時(shí),需要重啟進(jìn)程
4)RDS for MySQL中DDL操作不做同步處理;
5)更新app.conf需要重啟插件進(jìn)程才能生效;
6)如果工具出現(xiàn)bug或某種其它原因需要重新同步歷史數(shù)據(jù),只能回溯最近24小時(shí)的數(shù)據(jù)(在阿里云數(shù)據(jù)傳輸?shù)目刂婆_(tái)中修改消費(fèi)位點(diǎn));
7)插件的最大同步性能與運(yùn)行插件的服務(wù)器的互聯(lián)網(wǎng)帶寬和磁盤IOPS成正比。
4. 運(yùn)行dts-ads-writer/bin/startup.sh(sh bin/startup.sh);
5. 配置監(jiān)控程序監(jiān)控進(jìn)程存活和日志中的常見錯(cuò)誤碼。
logs目錄下的日志中的異常信息均以ErrorCode=XXXX ErrorMessage=XXXX形式給出,可以進(jìn)行監(jiān)控
如何使用PLSQL連接服務(wù)器上的數(shù)據(jù)庫,開發(fā)初學(xué)者都需要會(huì)這個(gè)問題。下面說一下步驟,幫助大家配置host并成功查詢數(shù)據(jù)。
1、首先鼠標(biāo)右鍵PLSQL,選擇屬性,打開PLSQL所在文件夾位置。
2、在文件夾中,找到instantclient文件夾。這里將該文件移出到PLSQL安裝文件外,方便之后修改。
3、然后在instantclient下,找到tnsnames.ora,用編輯器打開。
4、在tnsnames.ora中,可以配置數(shù)據(jù)庫連接。數(shù)據(jù)庫名稱、協(xié)議類型、host、port、sid。配置好之后,保存。
5、打開PLSQL,輸入username、password,選擇到配置的數(shù)據(jù)庫,進(jìn)行連接。點(diǎn)擊“file”--“new”--“SQL Window”,打開窗口,輸入查詢命令,F(xiàn)8執(zhí)行,連接成功了。
1、打開Tableau軟件。
2、在連接中,找到紅框位置的MySQL,點(diǎn)擊開始連接Mysql。
3、在彈出的連接界面,輸入Mysql服務(wù)器地址、端口、用戶名、密碼。
4、輸入完成后,點(diǎn)擊紅框位置 確認(rèn) 進(jìn)行連接。
5、此時(shí)已經(jīng)連接到MySQL服務(wù)器上,為了測(cè)試 我們點(diǎn)擊紅框位置 選擇數(shù)據(jù)庫查看一下。