這里要說明的是第三種方式,這種訪問方式完全遵循我們Ado.net 訪問SQL Server的模式,所以使用起來也更加得心應(yīng)手。
ADO.NET driver for MySQL 下載地址:
官方網(wǎng)站: http://www.mysql.com/downloads/
2.基礎(chǔ)數(shù)據(jù)庫操作
使用ADO.net 操作數(shù)據(jù)庫,固定不變的模式,五個核心對象
Connection: Connection 對象主要是開啟程序和數(shù)據(jù)庫之間的連結(jié)。沒有利用連結(jié)對象將數(shù)據(jù)庫打開,是無法從數(shù)據(jù)庫中取得數(shù)據(jù)的。
Command:Command 對象主要可以用來對數(shù)據(jù)庫發(fā)出一些指令,例如可以對數(shù)據(jù)庫下達(dá)查詢、新增、修改、刪除數(shù)據(jù)等指令,以及呼叫存在數(shù)據(jù)庫中的預(yù)存程序等。
DataAdapter: DataSetCommand 對象主要是在數(shù)據(jù)源以及DataSet 之間執(zhí)行數(shù)據(jù)傳輸?shù)墓ぷ鳎梢酝高^Command 對象下達(dá)命令后,并將取得的數(shù)據(jù)放入DataSet 對象中。
DataSet:DataSet 這個對象可以視為一個暫存區(qū)(Cache),可以把從數(shù)據(jù)庫中所查詢到的數(shù)據(jù)保留起來,甚至可以將整個數(shù)據(jù)庫顯示出來。DataSet 的能力不只是可以儲存多個Table 而已,還可以透過DataSetCommand 對象取得一些例如主鍵等的數(shù)據(jù)表結(jié)構(gòu),并可以記錄數(shù)據(jù)表間的關(guān)聯(lián)。DataSet 對象可以說是ADO.NET 中重量級的對象,這個對象架構(gòu)在DataSetCommand 對象上,本身不具備和數(shù)據(jù)源溝通的能力。
DataReader: 當(dāng)我們只需要循序的讀取數(shù)據(jù)而不需要其它操作時,可以使用DataReader 對象。DataReader對象只是一次一筆向下循序的讀取數(shù)據(jù)源中的數(shù)據(jù),而且這些數(shù)據(jù)是只讀的,并不允許作其它的操作。因?yàn)镈ataReader 在讀取數(shù)據(jù)的時候限制了每次只讀取一筆,而且只能只讀,所以使用起來不但節(jié)省資源而且效率很好.
代碼如下:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data.MySqlClient;
namespace CimDataImport
{
public class TestCharacter
{
public const string mysqlConnection = "User Id=root;Host=localhost;Database=cim;password=root";
/// <summary>
/// 添加數(shù)據(jù)
/// </summary>
/// <returns></returns>
public int Add(UserBase entity)
{
string sql = "INSERT INTO cimuser (userid,userNickName) VALUE (@userid,@userNickName)";
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection))
{
mycn.Open();
MySqlCommand command = new MySqlCommand(sql, mycn);
command.Parameters.AddWithValue("@userid", entity.UserId);
command.Parameters.AddWithValue("@userNickName",entity.UserNickName);
return command.ExecuteNonQuery();
}
}
/// <summary>
/// 修改數(shù)據(jù)
/// </summary>
/// <param name="entity"></param>
/// <returns></returns>
public int Update(UserBase entity)
{
string sql = "UPDATE cimuser SET userNickName=@userNickName WHERE userid=@userid";
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection))
{
mycn.Open();
MySqlCommand command = new MySqlCommand(sql, mycn);
command.Parameters.AddWithValue("@userid", entity.UserId);
command.Parameters.AddWithValue("@userNickName", entity.UserNickName);
return command.ExecuteNonQuery();
}
}
/// <summary>
/// 刪除數(shù)據(jù)
/// </summary>
/// <param name="primaryKey"></param>
/// <returns></returns>
public int Delete(int primaryKey)
{
string sql = "DELETE FROM cimuser WHERE userid=@userid";
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection))
{
mycn.Open();
MySqlCommand command = new MySqlCommand(sql, mycn);
command.Parameters.AddWithValue("@userid", primaryKey);
return command.ExecuteNonQuery();
}
}
/// <summary>
/// 根據(jù)主鍵查詢
/// </summary>
/// <param name="primaryKey"></param>
/// <returns></returns>
public UserBase Get(int primaryKey)
{
string sql = "SELECT userid,userNickName FROM cimuser where userid=@userid";
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection))
{
mycn.Open();
MySqlCommand command = new MySqlCommand(sql, mycn);
command.Parameters.AddWithValue("@userid", primaryKey);
MySqlDataReader reader = command.ExecuteReader();
UserBase userBase = null;
if (reader.Read())
{
userBase = new UserBase();
userBase.UserId = Convert.ToInt32(reader["userid"]);
userBase.UserNickName = reader["userNickName"] == DBNull.Value ? null : reader["userNickName"].ToString();
}
return userBase;
}
}
/// <summary>
/// 查詢集合
/// </summary>
/// <returns></returns>
public IList<UserBase> GetList()
{
string sql = "SELECT userid,userNickName FROM cimuser limit 1,10";
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection))
{
mycn.Open();
MySqlCommand command = new MySqlCommand(sql, mycn);
MySqlDataReader reader = command.ExecuteReader();
IList<UserBase> list = new List<UserBase>();
UserBase userBase = null;
while (reader.Read())
{
userBase = new UserBase();
userBase.UserId = Convert.ToInt32(reader["userid"]);
userBase.UserNickName = reader["userNickName"] == DBNull.Value ? null : reader["userNickName"].ToString();
list.Add(userBase);
}
return list;
}
}
}
}
3. ALinq 讓我變得如此簡單
在Linq 沒有現(xiàn)世之前,Ado.net 的數(shù)據(jù)庫操作讓我們感覺到編程的痛苦,每天重復(fù)著相同的數(shù)據(jù)庫操作代碼,后來千奇百怪的代碼生成器讓我們從中解脫出來,雖然有些代碼生成器的確非常不錯,但是心中始終覺得那些代碼少了一些什么!
Linq TO SQL 推出之后,我們感覺到了.net 語法的甜,是甜到心里的那種甜,感覺自己從代碼中徹底釋放出來!可是Linq To SQL 只支持微軟的 SQL Server 數(shù)據(jù)庫。
Alinq 是如此完美的解決了多類型數(shù)據(jù)庫操作的問題,在操作SQL Server 數(shù)據(jù)上毫不遜色Linq to SQL,在Mysql,Oracle,Db2 等數(shù)據(jù)庫操作上更甚一籌!第一: 新建工程
第二:添加新建項(xiàng)
這里使用控制臺程序![]()
第三: 新建數(shù)據(jù)庫連接
![]()
第四:添加Mysql數(shù)據(jù)庫連接
![]()
第五:選擇Mysql 數(shù)據(jù)源
![]()
第六:更改數(shù)據(jù)源
![]()
第七:輸入Mysql服務(wù)名以及賬號和密碼
![]()
第八:測試連接
![]()
第九:連接成功
![]()
上述操作是必須在安裝ADO.NET driver for MySQL 組件的情況下才能正常操作,否則第六步選擇更改數(shù)據(jù)源的時候看不到MySql database 選項(xiàng)。
Linq to sql 對于大家來說已經(jīng)很熟悉了,ALinq 的操作前面的文章也已經(jīng)詳細(xì)講解過了。這里操作不做詳細(xì)說明了!4. 中文你讓我如何說你
Mysql 數(shù)據(jù)庫開源,更重要的是它能夠運(yùn)行在Linux系統(tǒng)中!在工作中將Sql server 數(shù)據(jù)庫中的數(shù)據(jù)導(dǎo)入到Mysql 的時候,意想不到的事情發(fā)生了,中文在Mysql 中都變成了亂碼。而且Mysql 是安裝在Linux 系統(tǒng)上的。
Linux 中Mysql解決亂碼問題方案以及操作步驟:
1. 查找Mysql 下的.cnf 配置文件
在windows系統(tǒng)中安裝mysql程序,其中保存保存數(shù)據(jù)的配置文件名為 my.ini
此文件存在于mysql安裝目錄下,使用記事本打開此文件修改內(nèi)容如下:
將 default-character-set=utf8 (有兩處)更改為 default-character-set=GBK 并且添加節(jié)點(diǎn):character_set=gbk
![]()
在Linux中首先查找mysql 的配置文件命令如下:
find -name *.cnf –print
得到如下結(jié)果:
![]()
2. 將Mysql 中的一個cnf文件復(fù)制到etc文件目錄下,并且保存為my.cnf
在etc 目錄下查找my.cnf 文件,如果此文件不存在則需要從1中查找的文件中my-large.cnf,
My-small.cnf,my-medium.cnf 三個文件中復(fù)制一個到etc目錄下面,并且保存my.cnf 文件。
使用命令:
cp /usr/share/mysql/my-large.cnf /etc/
mv etc/my-large.cnf etc/my.cnf
文件復(fù)制到特定目錄,并且重新命名。
3. 修改my.cnf 配置文件
cd etc/ 進(jìn)入etc目錄下
vi my.cnf 使用vi命令打開my.cnf 文件
![]()
如果文件中存在此節(jié)點(diǎn),則將編碼方式修改為gbk
4. 重新啟動服務(wù)
/etc/init.d/mysql restart 重新啟動mysql 服務(wù)
5. 再次導(dǎo)入數(shù)據(jù)成功
聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com