1、首先在Navicat for MySQL 管理器中，创建目标数据库。
2、点击创建好的目标数据库website点的”表“一项，在右边会出现导入向导选项。
3、选择SQL Server数据库ODBC，“下一步”，数据链接属性－SQLSERVER-ODBC。
4、创建访问SQL SERVER ODBC。
5、回到导入向导中发现，已经可以查看到SQL Server源数据库中所有的表，选择需要导入的表，选择“添加”。
6、“下一步”-》“开始导入”，就可以了。
(1)首先需要下载C#访问MySQL数据库的ADO.NET驱动程序mysql-connector-net-6.3.8.msi
(2)安装mysql-connector-net
然后直接在Windows *** 作系统安装 mysql-connector-net-6.3.8.msi
(3)封装数据库访问组件DbConnectionMySQL
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
/// <summary>
/// MySQL数据库
/// 版本 mysql-connector-net-6.3.8.msi
/// </summary>
[Serializable]
public class DbConnectionMySQL : DbConnectionWrapper
{
public DbConnectionMySQL(string pConnectionString)
: base(pConnectionString)
{
this.m_dbconn = new MySqlConnection(pConnectionString)
this.m_DbConnState = DbConnState.Free
}
//--
public override DbDataAdapter GetDbDataAdapter()
{
return new MySqlDataAdapter()
}
public override DbDataAdapter GetDbDataAdapter(DbCommand dbCommand)
{
return new MySqlDataAdapter(dbCommand as MySqlCommand)
}
public override DbCommand GetDbCommand()
{
return new MySqlCommand()
}
public override DbConnection GetDbConnection()
{
return new MySqlConnection()
}
public override DbCommandBuilder GetDbCommandBuilder()
{
return new MySqlCommandBuilder()
}
public override DataProviderType GetCurrentDataProviderType()
{
return DataProviderType.Sql
}
public override bool IsExistsTable(string TableName, string UserName)
{
#region information
bool rbc = false //TABLES表中去查询 table_name
string dSql = "select * from TABLES where table_name='" + TableName + "'"
DataSet ds = this.ExecuteDataSet(dSql)
if (ds != null)
{
if (ds.Tables[0].Rows.Count >0)
{
rbc = true
}
else
{
rbc = false
}
}
else
{
rbc = false
}
return rbc
#endregion
}
public override bool IsExistsField(string FieldName, string TableName)
{
#region information
bool rbc = false
string dSql = ""
dSql = "select * from " + TableName + " where 1<>1"
DataSet ds = this.ExecuteDataSet(dSql)
if (ds != null)
{
DataTable dt = ds.Tables[0]
for (int j = 0j <dt.Columns.Countj++)
{
if (dt.Columns[j].ColumnName.ToString().ToUpper() == FieldName.ToString().ToUpper())
{
rbc = true
goto Return_End
}
}
dt.Dispose()
dt = null
}
ds.Dispose()
ds = null
Return_End:
return rbc
#endregion
}
public override char ParameterChar
{
get
{
return ':' //SQLite的参数符号为:
}
}
public override DbParameter CreateParameter(string name, object value)
{
return new MySqlParameter(name, value)
}
public override DbParameter CreateParameter(string name)
{
DbParameter dbp = new MySqlParameter()
dbp.ParameterName = name
return dbp
}
public override DbParameter CreateParameter(string name, DbType dbtype, object value)
{
DbParameter dbp = new MySqlParameter()
dbp.ParameterName = name
dbp.Value = value
dbp.DbType = dbtype
return dbp
}
public override DbParameter CreateParameter(string name, DbType dbtype, int size, object value)
{
DbParameter dbp = new MySqlParameter()
dbp.ParameterName = name
dbp.Value = value
dbp.DbType = dbtype
dbp.Size = size
return dbp
}
}
（4)客户端开发实例
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
public void TestCShape_MySQL()
{
string constr = "server=localhostUser Id=rootpassword=rootDatabase=xp_users"
DbConnectionWrapper dbw = new DbConnectionMySQL(constr)
bool rbc=dbw.TestConnection()
this.Context.Response.Write(rbc)
string x = ""
//删除语句
x = "delete from xp_users"
if (dbw.ExecuteQuery(x) >0)
{
this.Context.Response.Write("删除语句成功!下面是<a href="https://www.baidu.com/s?wd=SQL%E8%AF%AD%E5%8F%A5&tn=44039180_cpr&fenlei=mv6quAkxTZn0IZRqIHckPjm4nH00T1dBnvD3Pjn3uWbvnj9WmyNW0ZwV5Hcvrjm3rH6sPfKWUMw85HfYnjn4nH6sgvPsT6KdThsqpZwYTjCEQLGCpyw9Uz4Bmy-bIi4WUvYETgN-TLwGUv3EnHmsPHndP101n1nLnjDYPHD3Ps" target="_blank" class="baidu-highlight">SQL语句</a>" + x)
}
//插入语句
x = "insert into xp_users(gid,uid,uname,sex,email,pwd) values('"
x += "1','hsg77','何XXX',1,'hsg77@163.com','1')"
if (dbw.ExecuteQuery(x) >0)
{
this.Context.Response.Write("插入语句成功!下面是<a href="https://www.baidu.com/s?wd=SQL%E8%AF%AD%E5%8F%A5&tn=44039180_cpr&fenlei=mv6quAkxTZn0IZRqIHckPjm4nH00T1dBnvD3Pjn3uWbvnj9WmyNW0ZwV5Hcvrjm3rH6sPfKWUMw85HfYnjn4nH6sgvPsT6KdThsqpZwYTjCEQLGCpyw9Uz4Bmy-bIi4WUvYETgN-TLwGUv3EnHmsPHndP101n1nLnjDYPHD3Ps" target="_blank" class="baidu-highlight">SQL语句</a>"+x)
}
//查询语句
DataTable dt = dbw.ExecuteDataTable("select * from xp_users")
if (dt != null &&dt.Rows.Count >0)
{
this.Context.Response.Write("用户数:"+dt.Rows.Count)
}
if (dt != null)
{
dt.Dispose()
dt = null
}
dbw.Dispose()
dbw = null
}
1.添加mysql数据库驱动启动netbeans开发工具，在services(服务)窗口中展开databases(数据库)节点，大家就可以看到一个数据库的资源管理器
其中在Drivers包中包含了所有数据库的驱动程序，如果要使用netbeans来 *** 作mysql，必需在这里添加mysql的驱动程序，右键单击 Drivers(驱动程序)节点，然后选中“New Dirver...”命令，打开一个新建JDBC驱动程序的窗体
在这个新建对话框中选择add(添加)按钮，选择你要添加的驱动(mysql数据库驱动mysql-connector-java-3.1.3-beta-bin.jar)，添加确定后netbeans会自动填写Drivers Class:(com.mysql.jdbc.Driver)及Name文本输入框，然后打击Ok，完成数据库驱动程序在netbeans上的配置。
2.通过netbeans连接mysql数据库
前面工作都做好后，我们可以用netbeans当mysql的客户端来 *** 作mysql数据库。右击databases(数据库)节点，选择”new connection ...“(新建一个连接)选项，d出如下界面，其中name(名称)为上面配好的数据库驱动的名称，host(主机)为mysql数据库的计算机名或者 ip地址，port为mysql的端口号，默认为3306database为要连接的数据库的名字(如yang为本人建立的数据库)，然后输入数据库的 用户名和密码，单击OK(确定)按钮
完成后，将在databases(数据库)节点下多出一项我们自己刚添加的数据库，右击它，然后选择connect(连接)，将会打开我们要连接的mysql数据库。
其中Tables是yang这个数据库中所建的表，Views为视图，procedures为存储过程，在这里我们可以直观的看到数据库的结构，我们可以通过netbeans对mysql数据库进行各种 *** 作。
3。 *** 作数据库
如果要查看person表中的数据，可以右键单击person，选择view data(查看数据)选项，马上显示组合窗体，上面为sql编辑器
这里我们能够清楚看到person表中有2条数据，当然我们也可以在上面的SQL编辑器当中编写sql语句查询我们所需要的数据，在这里我们可以做很多命令行下 *** 作mysql数据库功能的 *** 作。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）