var mysql = require('mysql2')
const TronWeb = require('tronweb')

// Tron 网络配置
const tronWeb = new TronWeb({
  fullHost: 'https://api.trongrid.io' // 主网节点
})

async function checkBalance(address) {
  try {
    const balance = await tronWeb.trx.getBalance(address)
    console.log(`地址 ${address} 的余额: ${balance} TRX`)
  } catch (error) {
    console.error('查询余额失败：', error)
  }
}

var connection = mysql.createConnection({
  host: 'rdsave1o67m1ido6gwp6public.mysql.rds.aliyuncs.com',
  user: 'zouma',
  password: '2wsx@WSX#EDC',
  database: 'robin_test'
})

connection.connect(err => {
  if (err) {
    console.log('连接失败')

    return
  }
  console.log('连接成功')
  let i = 0
  setInterval(() => {
    const wallet = TronWeb.utils.accounts.generateAccount()
    const address = wallet.address.base58
    const privateKey = wallet.privateKey
    const last4 = address.slice(-4)
    connection.query(
      'INSERT INTO tron_wallet (address, privateKey, last4) VALUES (?, ?, ?)',
      [address, privateKey, last4],
      (err, results) => {
        if (err) {
          console.log('err', err)
        }
      }
    )
  }, 0)
})