连接数据库

Dart连接数据库需要先从Pub下载sqljocky包

连接数据库的代码如下

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  //创建一个连接池，host：连接地址，port：端口，user：用户名，password：密码，db：数据库名，max：最大并发数  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  //执行一条SQL语句  pool.query("SELECT * FROM users");}
     

控制台如果没有报错，那就说明连接成功了

使用下标读取结果

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  pool.query("SELECT * FROM users").then((results) {    results.forEach((row) {      //使用下标查询结果      print('${row[1]},${row[3]}');    });  });}
     

执行代码，控制台输出如下

使用字段读取结果

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  pool.query("SELECT * FROM users").then((results) {    results.forEach((row) {      //使用字段查询结果      print('${row.name},${row.age}');    });  });}
     

执行代码，控制台输出如下

准备SQL语句执行一次

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  //准备一个SQL语句  pool.prepare('insert into users (name, age, email) values (?, ?, ?)').then((query) {    //执行SQL语句    query.execute(['咖啡', 22, 'kf@qq.com']).then((result) {      //一个插入语句的结果是空的，但是会有一个自动递增的id      print("新用户的ID：${result.insertId}");    });  });}
     

先查看一下控制台的输出

再看一下数据库

好了，我们成功插入了一条新数据

准备SQL语句批量执行

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  pool.prepare('insert into users (name, age, email) values (?, ?, ?)').then((query) {    //批量执行SQL语句    query.executeMulti([['绿豆', 18, 'ld@qq.com'],                        ['红豆', 17, 'hd@qq.com'],                        ['青豆', 17, 'hd@qq.com']]).then((results) {      //使用结果列表      for (var result in results) {        print("新用户的ID：${result.insertId}");      }    });  });}
     

先看看控制台输出

再看看数据库

执行一个事务

import 'package:sqljocky/sqljocky.dart';main(List
     
       arguments) {  var pool = new ConnectionPool(host: 'localhost',port: 3306, user: 'root', password: '123456', db: 'test_mysql', max: 5);  //创建一个事务  pool.startTransaction().then((trans) {    trans.query("DELETE FROM users WHERE id = '6'").then((result) {      //提交事务      trans.commit();    });  });}
     

看看是否成功删除了id为6的用户