Flutter MySQL数据库连接插件galileo_mysql的使用

Flutter MySQL数据库连接插件galileo_mysql的使用

galileo_mysql 是一个用于Dart编程语言的MySQL驱动程序，适用于Flutter和服务器端开发。该库提供了一个易于使用的接口来与MySQL进行交互，最初是基于SQLJocky驱动程序的分叉版本。

使用方法

1. 连接到数据库

首先，你需要创建一个 ConnectionSettings 对象来配置数据库连接参数，然后使用 MySqlConnection.connect() 方法建立连接。

var settings = ConnectionSettings(
  host: 'localhost', 
  port: 3306,
  user: 'dart_jaguar',
  password: 'dart_jaguar',
  db: 'example'
);

var conn = await MySqlConnection.connect(settings);

2. 执行带参数的查询

你可以通过 conn.query() 方法执行SQL查询，并传递参数以防止SQL注入。以下是一个示例，查询用户表中ID为1的用户信息：

var userId = 1;
var results = await conn.query('select name, email from users where id = ?', [userId]);

for (var row in results) {
  print('Name: ${row[0]}, email: ${row[1]}');
}

3. 插入数据

使用 conn.query() 方法可以插入数据到表中。插入操作返回的结果集通常是空的，但如果表中有自增列，则可以通过 result.insertId 获取新插入行的ID。

var result = await conn.query('insert into users (name, email, age) values (?, ?, ?)', ['Bob', 'bob@bob.com', 25]);
print("New user's id: ${result.insertId}");

4. 批量插入数据

你还可以使用 queryMulti() 方法一次性插入多条记录。

var results = await conn.queryMulti(
    'insert into users (name, email, age) values (?, ?, ?)',
    [
      ['Bob', 'bob@bob.com', 25],
      ['Bill', 'bill@bill.com', 26],
      ['Joe', 'joe@joe.com', 37]
    ]
);

5. 更新数据

使用 conn.query() 方法可以更新表中的数据。以下是一个示例，将名为 “Bob” 的用户的年龄更新为26。

await conn.query('update users set age=? where name=?', [26, 'Bob']);

6. 完整示例代码

以下是一个完整的示例代码，展示了如何使用 galileo_mysql 插件连接到MySQL数据库，创建表，插入数据，查询数据，更新数据，并最终关闭连接。

import 'dart:async';
import 'package:galileo_mysql/galileo_mysql.dart';

Future main() async {
  // 打开连接（确保example数据库已存在）
  final conn = await MySqlConnection.connect(
      ConnectionSettings(
        host: 'localhost', 
        port: 3306, 
        user: 'dart_jaguar', 
        password: 'dart_jaguar', 
        db: 'example'
      )
  );

  try {
    // 创建users表
    await conn.query(
        'CREATE TABLE IF NOT EXISTS users ('
        'id int NOT NULL AUTO_INCREMENT PRIMARY KEY, '
        'name varchar(255), '
        'email varchar(255), '
        'age int)'
    );

    // 插入数据
    var result = await conn.query('insert into users (name, email, age) values (?, ?, ?)', ['Bob', 'bob@bob.com', 25]);
    print('Inserted row id=${result.insertId}');

    // 查询数据
    var results = await conn.query('select name, email, age from users where id = ?', [result.insertId]);
    for (var row in results) {
      print('Name: ${row[0]}, email: ${row[1]}, age: ${row[2]}');
    }

    // 更新数据
    await conn.query('update users set age=? where name=?', [26, 'Bob']);

    // 再次查询数据
    var results2 = await conn.query('select name, email, age from users where id = ?', [result.insertId]);
    for (var row in results2) {
      print('Name: ${row[0]}, email: ${row[1]}, age: ${row[2]}');
    }
  } finally {
    // 关闭连接
    await conn.close();
  }
}