- 综合排序
- 最热优先
- 最新优先
- 来自专栏码匠的流水账
聊聊canal的MysqlConnection
序 本文主要研究一下canal的MysqlConnection ha.jpg ErosaConnection canal-1.1.4/parse/src/main/java/com/alibaba/ class MysqlConnection implements ErosaConnection { private static final Logger logger fork() { MysqlConnection connection = new MysqlConnection(); connection.setCharset(getCharset public class MysqlConnection implements ErosaConnection { //...... public class MysqlConnection implements ErosaConnection { //......
98300发布于 2020-04-25 - 来自专栏码匠的流水账
聊聊canal的MysqlConnection
序 本文主要研究一下canal的MysqlConnection ErosaConnection canal-1.1.4/parse/src/main/java/com/alibaba/otter/canal class MysqlConnection implements ErosaConnection { private static final Logger logger = fork() { MysqlConnection connection = new MysqlConnection(); connection.setCharset(getCharset public class MysqlConnection implements ErosaConnection { //...... public class MysqlConnection implements ErosaConnection { //......
73110发布于 2020-04-26 - 来自专栏码匠的流水账
聊聊canal的MysqlDetectingTimeTask
mysqlConnection; public MysqlDetectingTimeTask(MysqlConnection mysqlConnection){ this.mysqlConnection = mysqlConnection; } public void run() { try { mysqlConnection.isConnected()) { mysqlConnection.connect(); } TimerTask，其run方法在reconnect为true时，更新reconnect为false，然后执行mysqlConnection.reconnect()；若reconnect为false且mysqlConnection.isConnected ()；若reconnect为false且mysqlConnection.isConnected()为false则执行mysqlConnection.connect()；之后执行detectingSQL语句
58000发布于 2020-04-20 - 来自专栏码匠的流水账
聊聊canal的MysqlDetectingTimeTask
mysqlConnection; public MysqlDetectingTimeTask(MysqlConnection mysqlConnection){ this.mysqlConnection = mysqlConnection; } public void run() { try { mysqlConnection.isConnected()) { mysqlConnection.connect(); } TimerTask，其run方法在reconnect为true时，更新reconnect为false，然后执行mysqlConnection.reconnect()；若reconnect为false且mysqlConnection.isConnected ()；若reconnect为false且mysqlConnection.isConnected()为false则执行mysqlConnection.connect()；之后执行detectingSQL语句
63020发布于 2020-04-22 - 来自专栏CBeann的博客
NET连接MySQL数据库的CRUD
string sqlCconnStr = ConfigurationManager.ConnectionStrings["MySqlStr"].ConnectionString; MySqlConnection sqlCon = new MySqlConnection(sqlCconnStr);//连接数据库 //打开连接 sqlCon.Open(); sqlCon = new MySqlConnection(sqlCconnStr);//连接数据库 //打开连接 sqlCon.Open(); sqlCon = new MySqlConnection(sqlCconnStr);//连接数据库 //打开连接 sqlCon.Open(); sqlCon = new MySqlConnection(sqlCconnStr);//连接数据库 //打开连接 sqlCon.Open(); /
51910编辑于 2023-12-25 - 来自专栏静心物语313的Coding
B7第七章第 1 节： ADO.Net简介
conn = new MySqlConnection("Server=localhost;Database=study1;uid=root;pwd=root;Charset=utf8")) using conn = new MySqlConnection("Server=127.0.0.1;Database=study1;uid=root;pwd=root;Charset=utf8")) using conn = new MySqlConnection("Server=127.0.0.1;Database=study1;uid=root;pwd=root;Charset=utf8")) using conn = 73 new MySqlConnection("Server=127.0.0.1;Database=study1;uid=root;pwd=root;Charset=utf8") conn = new MySqlConnection(connstr))//这里千万不要使用使用using进行资源的释放，， MySqlConnection conn = new
2K20发布于 2020-03-24 - 来自专栏明明如月的技术专栏
C# 连接MYSQ示例（全面）
conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString conn = new MySQLConnection(new MySQLConnectionString("localhost", "housing", "root", "root").AsString
1.2K20发布于 2021-08-27 - 来自专栏个人随笔
C#连接操作MySQL数据库 帮助类
. /// /// <returns>返回MySqlConnection对象</returns> public MySqlConnection M_str_sqlcon = "server=localhost;port=3306;user id=root;password=root;database=abc"; //根据自己的设置 MySqlConnection myCon = new MySqlConnection(M_str_sqlcon); return myCon; } #endregion M_str_sqlstr">SQL语句</param> public void getmysqlcom(string M_str_sqlstr) { MySqlConnection 对象</returns> public MySqlDataReader getmysqlread(string M_str_sqlstr) { MySqlConnection
4.5K30发布于 2018-07-05 - 来自专栏王磊的博客
MySQL数据库工具类之——DataTable批量加入MySQL数据库(Net版)
con = new MySqlConnection(connectionString)) { con.Open(); using (MySqlCommand con = new MySqlConnection(connectionString)) { con.Open(); using (MySqlCommand , params MySqlParameter[] parameters) { DataSet dataset = new DataSet(); using (MySqlConnection con = new MySqlConnection(connectionString)) { con.Open(); using (MySqlCommand con = new MySqlConnection(connectionString)) { con.Open(); using (MySqlCommand
3.8K90发布于 2018-05-08 - 来自专栏方亮
从0开始搭建编程框架——插件
{ namespace plugins { namespace mysql_conns { using peleus::plugins::configure::mysql_connection; MysqlConnection ::MysqlConnection() { _conn = NULL; } MysqlConnection::~MysqlConnection() { _disconnect(); } void MysqlConnection::init(const mysql_connection& conf) { _conf.CopyFrom(conf); } int MysqlConnection ::_reconnct() { if (_conn) { _disconnect(); } return _connect(); } int MysqlConnection * conn = new MysqlConnection(); conn->init(_conf.conn_info()); _unused.push_back(conn
97920发布于 2019-01-16 - 来自专栏.NET开发者社区
一步一步创建ASP.NET MVC5程序[Repository+Autofac+Automapper+SqlSugar](二)
connection = new MySqlConnection(connectionString)) { using (MySqlCommand connection = new MySqlConnection(connectionString)) { using (MySqlCommand connection = new MySqlConnection(connectionString)) { MySqlCommand cmd = connection = new MySqlConnection(connectionString)) { MySqlCommand cmd = connection = new MySqlConnection(connectionString)) { MySqlCommand cmd =
2.8K100发布于 2018-01-29 - 来自专栏跟着阿笨一起玩NET
C#/.NET/.NET Core Dapper 批量删除、新增、修改说明
connectionStrings> 3、dapper 数据库连接方法 Mysql连接方法： public class DapperService { public static MySqlConnection MySqlConnection() { string mysqlConnectionStr = ConfigurationManager.ConnectionStrings["MysqlServer "].ToString(); var connection = new MySqlConnection(mysqlConnectionStr); connection.Open(); MySqlConnection() { string mysqlConnectionStr = ConfigurationManager.ConnectionStrings["MysqlServer "].ToString(); var connection = new MySqlConnection(mysqlConnectionStr); connection.Open(); return
2.2K20编辑于 2023-03-09 - 来自专栏云计算linux
C#通用类
password=root;database=school;charset=utf8"; //1.获得通用连接对象 ；static,是否可以去掉; public static MySqlConnection getConn() { MySqlConnection conn = new MySqlConnection(str); conn.Open(); conn; } //2.关闭连接;关闭的连接对象，所以参数是连接对象 public static void close(){ MySqlConnection MySqlConnection conn = getConn(); MySqlCommand comm = new MySqlCommand(sql,conn); //sql是从外部传过来的命令语句 MySqlConnection conn = getConn(); MySqlDataAdapter adapter = new MySqlDataAdapter(sql, conn
30210编辑于 2024-12-19 - 来自专栏明明如月的技术专栏
C#（.net） MySql数据库链接工具类
conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString)) static object ExecuteScalar(String sql, MySQLParameter[] parameters) { using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString)) conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString)) conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString))
2.7K30发布于 2021-08-27 - 来自专栏米扑专栏
C#连接数据库SQL(2005)
首先来总结一下进行数据库编程的全过程,这里用的是SQL SERVER (1) 建立SqlConnection对象以连接数据库 SqlConnection mysqlconnection=new (9) 关闭SqlConnection对象 mysqlconnection.Close(); 下面把过程呈现出来. 1、在我的程序中用的是SQL,所以在程序头前加上 using System.Data.SqlClient try { mysqlconnection = new SqlConnection("server=localhost; Integrated Security=True;Database=myfriends "); mysqlcommand = mysqlconnection.CreateCommand(); //得到记录条数 mysqlcommand.CommandText = "SELECT COUNT (*) FROM Friends"; mysqlconnection.Open(); k = (int)mysqlcommand.ExecuteScalar(); GetData(1); }
1.6K30发布于 2019-02-19 - 来自专栏CSharp编程大全
C#连接MySQL数据库实例
Step2：using所需要的库 using MySql.Data.MySqlClient; step3：建立连接(MySqlConnection类) using MySql.Data.MySqlClient ; public MySqlConnection connect() { String connetStr = "server=127.0.0.1 ;port=3306;user=root;password=a123456.; database=thzdb;"; MySqlConnection con = new MySqlConnection connetStr = "server=127.0.0.1;port=3306;user=root;password=a123456.; database=thzdb;"; MySqlConnection con = new MySqlConnection(connetStr); con.Open(); Console.WriteLine("数据库连接成功
10.2K20发布于 2021-03-16 - 来自专栏Java
使用Kafka实现Java异步更新通知解决Redis与MySQL数据不一致
REDIS_PORT); jedis.select(REDIS_DB); // 连接MySQL Connection mysqlConnection } } // 关闭连接 jedis.close(); mysqlConnection.close Redis、MySQL和Kafka： Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT); jedis.select(REDIS_DB); Connection mysqlConnection > producer = new KafkaProducer<>(kafkaProps); 查询商品ID并检测库存一致性： PreparedStatement preparedStatement = mysqlConnection.prepareStatement producer.send(record); System.out.println("Async notification sent to Kafka."); 关闭连接： jedis.close(); mysqlConnection.close
29700编辑于 2025-01-21 - 来自专栏PPV课数据科学社区
【数据科学】R语言连接数据库
mysqlconnection = dbConnect(MySQL(), user='root', password='', dbname='sakila', host='localhost') # # Query the "actor" tables to get all the rows. result = dbSendQuery(mysqlconnection, "select * from result = dbSendQuery(mysqlconnection, "select * from actor where last_name='TORN'") # Fetch all the dbSendQuery(mysqlconnection, "update mtcars set disp = 168.5 where hp = 110") 在执行上面的代码后，我们可以看到该表在MySQL dbSendQuery(mysqlconnection, 'drop table if exists mtcars') 在执行上面的代码后，我们可以看到该表在MySQL环境被丢弃。 ?
1.8K50发布于 2018-04-23 - 来自专栏代码洁癖患者
【译】浅谈SOLID原则
Connection"); } } public class PasswordReminder { private MySQLConnection mySQLConnection; public PasswordReminder(MySQLConnection mySQLConnection) { this.mySQLConnection = mySQLConnection 在上面这段代码中，尽管将MySQLConnection类注入了PasswordReminder类，但它依赖于MySQLConnection。 而高层模块PasswordReminder是不应该依赖于低层模块MySQLConnection的。因此这不符合依赖倒置原则。 如果你想要把MySQLConnection改成MongoConnection，那就要在PasswordReminder中更改硬编码的构造函数注入。
68420发布于 2020-03-10 - 来自专栏知识分享
C#连接数据库插入数据
namespace MqttDemo { class DataBase { public static MySqlConnection getMySqlCon(string String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString; MySqlConnection mysql = new MySqlConnection(connetStr); return mysql; } public static void button18.Text == "连接") { mySqlConnection DataBase.getMySqlCon(name, password, ip, port, database, charset); mySqlConnection.Open
3K20发布于 2018-12-14
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号