C#中如何设置字符串连接到MySQL数据库？

Posted 2023-05-07

#region  建立mysql数据库连接
    /// <summary>
    /// 建立数据库连接.
    /// </summary>
    /// <returns>返回MySqlConnection对象</returns>
    public MySqlConnection getmysqlcon()
    
    //http://sosoft.cnblogs.com/
        string M_str_sqlcon = "server=localhost;user id=root;password=root;database=abc"; //根据自己的设置
        MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);
        return myCon;
    
    #endregion

    #region  执行MySqlCommand命令
    /// <summary>
    /// 执行MySqlCommand
    /// </summary>
    /// <param name="M_str_sqlstr">SQL语句</param>
    public void getmysqlcom(string M_str_sqlstr)
    
        MySqlConnection mysqlcon = this.getmysqlcon();
        mysqlcon.Open();
        MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
        mysqlcom.ExecuteNonQuery();
        mysqlcom.Dispose();
        mysqlcon.Close();
        mysqlcon.Dispose();
    
    #endregion

#region  创建MySqlDataReader对象
    /// <summary>
    /// 创建一个MySqlDataReader对象
    /// </summary>
    /// <param name="M_str_sqlstr">SQL语句</param>
    /// <returns>返回MySqlDataReader对象</returns>
    public MySqlDataReader getmysqlread(string M_str_sqlstr)
    
        MySqlConnection mysqlcon = this.getmysqlcon();
        MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
        mysqlcon.Open();
        MySqlDataReader mysqlread = mysqlcom.ExecuteReader(CommandBehavior.CloseConnection);
        return mysqlread;
    
    #endregion

参考技术A

mysql.data.dll下载_c#连接mysql必要插件

全部版本下载：http://hovertree.com/h/bjaf/0sft36s9.htm

mysql.data.dll是C#操作MYSQL的驱动文件，是c#连接mysql必要插件，使c#语言更简洁的操作mysql数据库。当你的电脑弹出提示“丢失mysql.data.dll”或“无法找到mysql.data.dll”等错误问题，请下载本站为你提供的dll文件，使用它可以帮助用户解决上述问题。
dll文件修复方法：
1、解压下载的文件。
2、复制文件“mysql.data.dll”到系统目录下。
3、系统目录一般为：C:\\WINNT\\System32 64位系统为C:\\Windows\\SysWOW64
4、最后点击开始菜单-->运行-->输入regsvr32 mysql.data.dll 后，回车即可解决错误提示！ 

第三方组件：Mysql.Data.dll
说明：下载Mysql.Data.dll，然后在项目中添加该组件的引用，在代码页里输入using Mysql.Data.MysqlClient，我们就可以顺利的使用该类库的函数建立连接了。

以下是几个常用函数：

1 #region  建立MySql数据库连接 2     /// <summary> 3     /// 建立数据库连接. 4     /// </summary> 5     /// <returns>返回MySqlConnection对象</returns> 6     public MySqlConnection getmysqlcon() 7      8     //http://sosoft.cnblogs.com/ 9         string M_str_sqlcon = "server=localhost;user id=root;password=root;database=abc"; //根据自己的设置10         MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);11         return myCon;12     13     #endregion14 15     #region  执行MySqlCommand命令16     /// <summary>17     /// 执行MySqlCommand18     /// </summary>19     /// <param name="M_str_sqlstr">SQL语句</param>20     public void getmysqlcom(string M_str_sqlstr)21     22         MySqlConnection mysqlcon = this.getmysqlcon();23         mysqlcon.Open();24         MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);25         mysqlcom.ExecuteNonQuery();26         mysqlcom.Dispose();27         mysqlcon.Close();28         mysqlcon.Dispose();29     30     #endregion31 32 #region  创建MySqlDataReader对象33     /// <summary>34     /// 创建一个MySqlDataReader对象35     /// </summary>36     /// <param name="M_str_sqlstr">SQL语句</param>37     /// <returns>返回MySqlDataReader对象</returns>38     public MySqlDataReader getmysqlread(string M_str_sqlstr)39     40         MySqlConnection mysqlcon = this.getmysqlcon();41         MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);42         mysqlcon.Open();43         MySqlDataReader mysqlread = mysqlcom.ExecuteReader(CommandBehavior.CloseConnection);44         return mysqlread;45     46     #endregion

1 using System.Data;  2   3 using MySql.Data.MySqlClient;  4   5   6   7   8   9 private MySqlConnection conn; 10  11 private DataTable data; 12  13 private MySqlDataAdapter da; 14  15 private MySqlCommandBuilder  cb; 16  17 private DataGrid  dataGrid; 18  19  20  21 private void connectBtn_Click(object sender, System.EventArgs e) 22  23   24  25  if (conn != null) 26  27  conn.Close(); 28  29   30  31  string connStr = String.Format("server=0;user id=1; password=2; port=3; database=mysql; pooling=false; charset=utf8", 32  33  server.Text, userid.Text, password.Text, 3306); 34  35  36  37  try  38  39   40  41  conn = new MySqlConnection( connStr ); 42  43  conn.Open(); 44  45  46  47  GetDatabases(); 48  49                 MessageBox.Show("连接数据库成功!"); 50  51   52  53  catch (MySqlException ex)
54  55   56  57  MessageBox.Show( "Error connecting to the server: " + ex.Message ); 58  59   60  61   62  63  64  65  private void GetDatabases()
66  67   68  69  MySqlDataReader reader = null; 70  71  MySqlCommand cmd = new MySqlCommand("SHOW DATABASES", conn); 72  73  74  75  try  76  77   78  79  reader = cmd.ExecuteReader(); 80  81  databaseList.Items.Clear(); 82  83  while (reader.Read())
84  85   86  87  databaseList.Items.Add( reader.GetString(0) ); 88  89   90  91   92  93  catch (MySqlException ex)
94  95   96  97  MessageBox.Show("Failed to populate database list: " + ex.Message ); 98  99  100 101  finally 102 103  104 105  if (reader != null) reader.Close();106 107  108 109  110 111 112 113  private void databaseList_SelectedIndexChanged(object sender, System.EventArgs e)114 115  116 117  MySqlDataReader reader = null;118 119  conn.ChangeDatabase(databaseList.SelectedItem.ToString());120 121 //http://sosoft.cnblogs.com/122 123  MySqlCommand cmd = new MySqlCommand("SHOW TABLES", conn);124 125  try 126 127  128 129  reader = cmd.ExecuteReader();130 131  tables.Items.Clear();132 133  while (reader.Read())
134 135  136 137  tables.Items.Add( reader.GetString(0) );138 139  140 141  142 143  catch (MySqlException ex)
144 145  146 147  MessageBox.Show("Failed to populate table list: " + ex.Message );148 149  150 151  finally 152 153  154 155  if (reader != null) reader.Close();156 157  158 159  160 161 162 163  private void tables_SelectedIndexChanged(object sender, System.EventArgs e)164 165  166 167  data = new DataTable();168 169  170 171  da = new MySqlDataAdapter("SELECT * FROM " + tables.SelectedItem.ToString(), conn );172 173      cb = new MySqlCommandBuilder( da ); // 此处必须有，否则无法更新174 175 176 177  da.Fill( data );178 179 180 181  dataGrid.DataSource = data;182 183  184 185 186 187  private void updateBtn_Click(object sender, System.EventArgs e)188 189  190 191  DataTable changes = data.GetChanges();192 193  da.Update( changes );194 195  data.AcceptChanges();196 197  

如何将子查询中的字符串连接到mysql中的一行？

【中文标题】如何将子查询中的字符串连接到mysql中的一行？

【英文标题】：How do I concatenate strings from a subquery into a single row in mysql?

【发布时间】：2011-04-25 13:00:52

【问题描述】：

我有三张桌子：

table "package"
-----------------------------------------------------
package_id      int(10)        primary key, auto-increment
package_name    varchar(255)
price           decimal(10,2)

table "zones"
------------------------------------------------------
zone_id         varchar(32)    primary key (ex of data: A1, Z2, E3, etc)

table "package_zones"
------------------------------------------------------
package_id     int(10)
zone_id        varchar(32)

我要做的是返回包裹表中的所有信息以及该包裹的区域列表。我想要按字母顺序排序并以逗号分隔的区域列表。

所以我正在寻找的输出是这样的......

+------------+---------------+--------+----------------+
| package_id | package_name  | price  | zone_list      |
+------------+---------------+--------+----------------+
| 1          | Red Package   | 50.00  | Z1,Z2,Z3       |
| 2          | Blue Package  | 75.00  | A2,D4,Z1,Z2    |
| 3          | Green Package | 100.00 | B4,D1,D2,X1,Z1 |
+------------+---------------+--------+----------------+

我知道我可以在 PHP 中使用表示层做一些事情来获得所需的结果。问题是，我希望能够对 zone_list ASC 或 DESC 进行排序，甚至使用“WHERE zone_list LIKE”等等。为了做到这一点，我需要在 MYSQL 中完成。

我什至不知道如何开始解决这个问题。我尝试使用子查询，但它一直抱怨多行。我试图将多行连接成一个字符串，但显然 MySQL 不喜欢这样。

提前致谢。

更新！

这里是给感兴趣的人的解决方案。

SELECT 
    `package`.*,
    GROUP_CONCAT(`zones`.`zone` ORDER BY `zones`.`zone` ASC SEPARATOR ','  )  as `zone_list`
FROM 
    `package`,
    `package_zones`
LEFT JOIN 
    (`zones`,`ao_package_zones`) ON (`zones`.`zone_id` = `package_zones`.`zone_id` AND `package_zones`.`package_id` = `package`.`package_id`)
GROUP BY 
    `ao_package`.`package_id`

【问题讨论】：

在区域字段上使用 group by 和 group_concat

我用你的问题更新了部分选择角色。*，GROUP_CONCAT(rp.permission_id SEPARATOR ',') as permission_ids from roles join role_permissions rp on roles.id = rp.role_id GROUP BY roles.id。作品

【参考方案1】：

通过使用 GROUP_CONCAT() 函数和 GROUP BY 调用。这是一个示例查询

SELECT 
   p.package_id,
   p.package_name,
   p.price,
   GROUP_CONCAT(pz.zone_id SEPARATOR ',') as zone_list 
FROM 
   package p 
LEFT JOIN package_zone pz ON p.package_id = pz.package_id 
GROUP BY 
   p.package_id

您应该仍然可以按 zone_id （或 zone_list）进行排序，并且可以使用 LIKE 或类似的东西来代替 LIKE。

【讨论】：

如此接近。差不多了！我希望 zone_list 按字母顺序排序。这就是为什么我更多地考虑子查询。不过非常接近。

发现我可以在 GROUP CONCAT 中输入“ORDER BY”。所以 GROUP_CONCAT(pz.zone_id ORDER BY pz.zone_id ASC SEPARATOR ',') 工作！！！！

修订：没用。它总是为每一行返回所有可能的区域。每行应该只返回该特定包的区域。

我想出了如何防止所有可能的行返回。你必须做一个交叉连接。我会把答案放在问题中让所有人看到。

对于任何想在 SQL Server 中执行此操作的人：***.com/questions/6899/…