首页 / C# / c#读sql server数据添加到MySQL数据库

c#读sql server数据添加到MySQL数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c#读sql server数据添加到MySQL数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8677字，纯文字阅读大概需要13分钟。

内容图文

using System;
using System.Collections.Generic;
using System.Text;
using Console = System.Console;
using Microsoft.Data.Odbc;

using System.Data;
using System.Data.SqlClient;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {

            try
            {
                connSqlserver();
            }
            catch (OdbcException MyOdbcException)
            {
                for (int i = 0; i < MyOdbcException.Errors.Count; i++)
                {
                    Console.Write("ERROR #" + i + "\n" +
                    "Message: " + MyOdbcException.Errors[i].Message + "\n" +
                    "Native: " + MyOdbcException.Errors[i].NativeError.ToString() + "\n" +
                    "Source: " + MyOdbcException.Errors[i].Source + "\n" +
                    "SQL: " + MyOdbcException.Errors[i].SQLState + "\n");
                }
            }


            Console.ReadLine();

        }

        public void ceshi()
        {
            try
            {
                string MyConString = "DRIVER={MySQL ODBC 3.51 Driver};" +
                "SERVER=localhost;" +
                "DATABASE=jy;" +
                "UID=root;" +
                "PASSWORD=123;" +
                "OPTION=3;CharSet=gb2312;";

                OdbcConnection MyConnection = new OdbcConnection(MyConString);
                MyConnection.Open();

                Console.WriteLine("\n !!! success, connected successfully !!!\n");

                //Create a sample table
                OdbcCommand MyCommand = new OdbcCommand("DROP TABLE IF EXISTS my_odbc_net", MyConnection);
                MyCommand.ExecuteNonQuery();
                MyCommand.CommandText = "CREATE TABLE my_odbc_net(id int, name varchar(20), idb bigint)";
                MyCommand.ExecuteNonQuery();

                //Insert
                MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(10,‘" + filter("中国,‘‘") + "‘, 300)";
                Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery()); ;

                //Insert
                MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,‘mysql‘,400)";
                Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());

                //Insert
                MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,‘mysql‘,500)";
                Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());

                //Update
                MyCommand.CommandText = "UPDATE my_odbc_net SET id=999 WHERE id=20";
                Console.WriteLine("Update, Total rows affected:" + MyCommand.ExecuteNonQuery());

                //COUNT(*)
                MyCommand.CommandText = "SELECT COUNT(*) as TRows FROM my_odbc_net";
                Console.WriteLine("Total Rows:" + MyCommand.ExecuteScalar());

                //Fetch
                MyCommand.CommandText = "SELECT * FROM my_odbc_net";
                OdbcDataReader MyDataReader;
                MyDataReader = MyCommand.ExecuteReader();
                while (MyDataReader.Read())
                {
                    if (string.Compare(MyConnection.Driver, "myodbc3.dll") == 0)
                    {
                        Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " +
                        MyDataReader.GetString(1) + " " +
                        MyDataReader.GetInt64(2)); //Supported only by Connector/ODBC 3.51
                    }
                    else
                    {
                        Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " +
                        MyDataReader.GetString(1) + " " +
                        MyDataReader.GetInt32(2)); //BIGINTs not supported by Connector/ODBC
                    }
                }

                //Close all resources
                MyDataReader.Close();
                MyConnection.Close();
            }
            catch (OdbcException MyOdbcException)//Catch any ODBC exception ..
            {
                for (int i = 0; i < MyOdbcException.Errors.Count; i++)
                {
                    Console.Write("ERROR #" + i + "\n" +
                    "Message: " + MyOdbcException.Errors[i].Message + "\n" +
                    "Native: " + MyOdbcException.Errors[i].NativeError.ToString() + "\n" +
                    "Source: " + MyOdbcException.Errors[i].Source + "\n" +
                    "SQL: " + MyOdbcException.Errors[i].SQLState + "\n");
                }
            }
        }

        public static void connSqlserver()
        {
            string MyConString = "DRIVER={MySQL ODBC 3.51 Driver};" +
                "SERVER=localhost;" +
                "DATABASE=zs;" +
                "UID=root;" +
                "PASSWORD=123;" +
                "OPTION=3;CharSet=gb2312;";

            OdbcConnection MyConnection = new OdbcConnection(MyConString);
            MyConnection.Open();
            OdbcCommand MyCommand = new OdbcCommand("DROP TABLE IF EXISTS my_odbc_net", MyConnection);
            MyCommand.ExecuteNonQuery();

            //使用轻量级的SqlDataReader显示数据
            //指定Sql Server提供者的连接字符串
            string connString = "Data Source=PC-200908231053\\SQLEXPRESS;database=occupationNew;User id=sa;PWD=123";

            //建立连接对象

            SqlConnection Sqlconn = new SqlConnection(connString);
            //打开连接
            Sqlconn.Open();


            string thisCommand = "select * from Article where ID >"+ 1243931905062 +"order by ID";

            //创建SqlDataAdapter对象,有两个参数，一个是查询字符串，一个是连接对象
            SqlDataAdapter SqlDap = new SqlDataAdapter(thisCommand, Sqlconn);

            //创建DataSet对象

            DataSet thisDataset = new DataSet();

            //使用SqlDataAdapter的Fill方法填充DataSet，有两个参数，一个是创建的DataSet实例，一个是填入的表

            SqlDap.Fill(thisDataset, "informations");

            //显示查询结果

            foreach (DataRow theRow in thisDataset.Tables["informations"].Rows)
            {
                //Console.WriteLine(theRow["InformationId"] + "\t" + theRow["companyName"]);
                //MyCommand.CommandText = "INSERT INTO information(companyname,course,major,number,sex,pay,request,informationsource,datetime,job,workprovinci,detailplace,isbin,enddate,existcourse,academymajororder) "
                //    + "VALUES(‘" + filter(theRow["CompanyName"]) + "‘,‘" + filter(theRow["Course"]) + "‘,‘" + filter(theRow["Major"]) + "‘,‘" + filter(theRow["Number"]) + "‘,‘" + filter(theRow["Sex"]) + "‘,‘" + filter(theRow["Pay"]) + "‘,‘" + filter(theRow["request"]) + "‘,‘" + filter(theRow["informationSource"]) + "‘,‘" + filter(theRow["DateTime"]) + "‘,‘" + filter(theRow["Job"]) + "‘,‘" + filter(theRow["WorkProvince"]) + "‘,‘" + filter(theRow["DetailPlace"]) + "‘,‘" + filter(theRow["IsBin"]) + "‘,‘" + filter(theRow["EndDate"]) + "‘,‘" + filter(theRow["ExistCourse"]) + "‘,‘" + filter(theRow["AcademyMajorOrder"]) + "‘)";

                Console.WriteLine(theRow["ID"] + "\t" + theRow["Title"]);
                MyCommand.CommandText = "INSERT INTO downloads(title,fenlei,content,lint,updatetime,click) "
                    + "VALUES(‘" + filter(theRow["Title"]) + "‘,‘" + filter(theRow["CategoryID"]) + "‘,‘" + filter(theRow["Content"]) + "‘,‘" + filter(theRow["Author"]) + "‘,‘" + filter(theRow["DateTime"]) + "‘,‘" + filter(theRow["Hits"]) + "‘)";

                //Console.WriteLine(theRow["ID"] + "\t" + theRow["Title"]);
                //MyCommand.CommandText = "INSERT INTO xinwens(title,fenlei,content,username,updatetime,click) "
                //    + "VALUES(‘" + filter(theRow["Title"]) + "‘,‘" + "" + "‘,‘" + filter(theRow["Content"]) + "‘,‘" + filter("大学生就业指导中心") + "‘,‘" + filter(theRow["DateTime"]) + "‘,‘" + 0 + "‘)";


                Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());
            }
            Sqlconn.Close();

            Console.ReadLine();

        }

        public static string filter(object text)
        {
            System.Text.Encoding GB2312 = System.Text.Encoding.GetEncoding("GB2312");
            System.Text.Encoding UTF8 = System.Text.Encoding.UTF8;
            byte[] data = GB2312.GetBytes(text.ToString());
            string msg = GB2312.GetString(data);
            return msg.Replace(",", "，").Replace("‘", "’").Replace("―", "-");

        }
    }
}

c#读sql server数据添加到MySQL数据库

标签：localhost com 数据 connect 中心 bcd 学生 sage detail

本文系统来源：http://www.cnblogs.com/Fooo/p/7058574.html

内容总结

以上是互联网集市为您收集整理的c#读sql server数据添加到MySQL数据库全部内容，希望文章能够帮你解决c#读sql server数据添加到MySQL数据库所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/484554.html

来源：【匿名】

【上一篇】MongoDB 3.4版本， C# 驱动 2.4 操作【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【c#读sql server数据添加到MySQL数据库】教程文章相关的互联网学习教程文章

C# 之 EF CodeFirst创建MySQL数据库【图】

MySQL安装好了，今天跟大家交流一下怎么利用EntityFramework的CodeFirst在MySQL数据库中创建数据库目标框架：.NET Framework 4第一步：新建一个项目，然后添加如下的引用，这些引用可以在NuGet中添加，也可以到官网中下载然后添加第二步：在配置文件中添加数据库节点配置<span style="font-family:Arial;font-size:10px;"><?xml version="1.0"?> <configuration><startup> <supportedRuntime version="v4.0" sku=".NETFramework,Ve...

C#开发MySQL数据库程序时需要注意的几点

一：引用MySQL使用基于Parameter方式代码，总是提示:“Column ‘列名‘cannot be null”解决 MySQL使用基于Parameter方式代码，总是提示:“Column ‘列名‘ cannot be null” 解决方法1：直接在连接字符串里面加一个 oldsyntax=true 即可。例如： ?1server=127.0.0.1;userid=root;password=;database=itemdb;oldsyntax=true 解决方法2：将语句中的 @ 替换为 ? 例如： ?1234567891011121314151617StringBuilder strSql=new Strin...

c#连接mysql数据库字符串database属性值含有特殊符号“.”怎么转义【图】

mysqlc#

C#访问MySQL数据库（winform+EF）【图】

参考介绍： http://baike.baidu.com/link?url=jDHhtM4QGOpQJmgY9bCe24VJy4kgKAvsuRHJgGmuXlGilJ7lmVVzQkoVMX9KlYCmdagGACDm8042dQnR-E6_nq 另外还要说明的是EF的版本，我这里使用的是EF6，可以通过nuget工具包管理来获得最新版本以下是建立VS项目的步骤截图：以上步骤首先是新建一个MYSQL的连接，然后选择对应的表生成对应的EF实体框架，这样一个EF的winform项目基本就建立好了。 4、查看winfrom项目结构打开对应的*.tt文件，...

C#访问MySQL数据库（winform+EF）【代码】【图】

CREATE database My_OA 2 3 CREATE TABLE my_oa.sys_user 4 ( 5 id INT not NULL AUTO_INCREMENT PRIMARY KEY, 6 userName varchar(32), 7 pwd varchar(32) 8 9 ); 当然也可以使用图形界面来配置，直接鼠标右键来建表，主要是看个人的习惯了，熟悉的话直接SQL句会方便很多也比较快，这里我们快速的插入三条数据，便于以后测试使用，因为ID是自增的，所以可以不用管，插入后你会发现ID已经自己有了，只是MYSQL中AUTO_INCREMENT...

C#连接mysql数据库【代码】

System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Data.Odbc; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using MySQLDriverCS; namespace mysql1 { public partial class Form1 : Form { publicForm1() { InitializeComponent(); } privatevoid Form1_Load(ob...

C# asp.net 连接Mysql 数据库【代码】

using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.UI; using System.Web.UI.WebControls; using System.Data; using MySql.Data.MySqlClient;namespace WebApplication1 {public partial class addertong : System.Web.UI.Page{//数据库地址string ser = "Server=localhost;UserId=root;Password=password;Database=child;pooling=false;CharSet=utf8;port=3306";protecte...

C#第四次作业：MySQL数据库及C#操作MySQL数据库【图】

（1）在MySQL数据库中插入两个文件中的数据（注意：数据库创建的时候要选择gb2312 -- GB2312 Simplified Chinese，否则导不进去因为中文识别不了）把List_Class1.txt导入到mysql里：1.给txt文档里的数据加个属性2.TXT文件之前默认编码为ANSI，另存为编码为UTF-8的文本文件，这样导入mysql里才不会乱码3.开始导入4.导入成功把List_Class1_Submit.xls导入到mysql里：步骤和把.txt导入mysql里相似（2）利用SQL命令查找所有出现在“Li...

[C#] zdbviewcs: 跨平台数据库查看器。支持SqlServer、Oracle、MySql等数据库【图】

作者：zyl910 一、说明本工具有适合以下情况使用—— * 快速查看数据库中数据及表结构信息。* 测试ADO.Net下连接字符串的写法。* 帮忙分析ADO.Net数据库操作。二、用法运行本程序。在“Provider”下拉框中选择数据提供者工厂。（若没有的话，请尝试在 zdbviewcs.exe.config 中增加数据提供者工厂配置）。在“ConnectionString”文本框中填好连接字符串。点击“Open”按钮打开数据。打开数据库之后。会发现左边的“Table”分页中...

C#使用MysqlBackup.Net 备份MySQL数据库【代码】【图】

MySql.Data.dll 好了我们开始调用我们参考官方的代码实例 C#调用MySqlBackup.dll 备份Mysql数据库1 string constring = "server=localhost;user=root;pwd=qwerty;database=test;";2 string file = "C:\\backup.sql";3 using (MySqlConnection conn = new MySqlConnection(constring))4 {5 using (MySqlCommand cmd = new MySqlCommand())6 {7 using (MySqlBackup mb = new MySqlBackup(cmd))8 {9 ...

c# 连接Mysql数据库【代码】【图】

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_s...

c#访问mysql数据库

System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Data; using System.Data.SqlClient; using System.Collections; using System.Collections.Generic; using MySql.Data.MySqlClient; using System.Data;namespace ConsoleApplication8 {class Program{static void Main(string[] args){const string connStr = "server=localhost;database =storecode;user id=root; password=roo...