Skip to content

Instantly share code, notes, and snippets.

View mzhang77's full-sized avatar

Michael Zhang mzhang77

  • PingCAP
View GitHub Profile
@mzhang77
mzhang77 / upsert.py
Last active September 9, 2024 00:52
import mysql.connector
from mysql.connector import pooling
import sys
# Create a connection pool
dbconfig = {
"database": "test",
"user": "root",
@mzhang77
mzhang77 / upsert.go
Last active September 9, 2024 00:55
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/go-sql-driver/mysql"
)
import threading
import time
import mysql.connector
from mysql.connector import pooling
from collections import Counter
import sys
import mysql.connector
try:
connection = mysql.connector.connect(
host="127.0.0.1",
port="4000",
user="root",
password="",
database="test"
)
import mysql.connector
import subprocess
import os
db = 'test'
table = 'lineitem'
version = 'v8.3.0'
import mysql.connector
import re
slow_log_files = ['file1','file2']
table = "slow_log"
connection = mysql.connector.connect(
host="127.0.0.1",
import mysql.connector
from datetime import datetime
# Get Unix epoch time (1970-01-01 00:00:00)
epoch_time = datetime.utcfromtimestamp(0) # Unix time 0 in UTC
# MySQL-compatible timestamp string
formatted_time = epoch_time.strftime('%Y-%m-%d %H:%M:%S')
# /// script
# requires-python = ">=3.13"
# dependencies = [
# "mysql-connector-python",
# ]
# ///
import mysql.connector
# Database configuration
import threading
import mysql.connector
from mysql.connector import Error
import random
import string
import time
from datetime import datetime, timedelta
from collections import Counter
import logging
# /// script
# requires-python = ">=3.13"
# dependencies = [
# "mysql-connector-python",
# ]
# ///
import threading
import time