我无法在sqlite数据库flutter中保存图像



我正在尝试使用flutter将图像保存在sqlite数据库中。下面是我的助手类我想在哪里保存数据

class DBHelper{
static  Database? _db;
static const String ID = 'id';
static const String NAME = 'photo_name';
static const String TABLE = 'PhotosTable';
static const String DB_NAME = 'photos.db';

Future<Database> get db async {
if (null != _db) {
return _db!;
}
_db = await initDb();
return _db!;
}
initDb() async {
io.Directory documentsDirectory = await getApplicationDocumentsDirectory();
String path = join(documentsDirectory.path, DB_NAME);
var db = await openDatabase(path, version: 1, onCreate: _onCreate);
return db;
}
_onCreate(Database db, int version) async {
await db.execute("CREATE TABLE $TABLE ($ID INTEGER, $NAME TEXT)");}

Future<SaveImage> save(SaveImage employee) async {
var dbClient = await db;
employee.id = await dbClient.insert(TABLE, employee.toMap());
return employee;
}
Future<List<SaveImage>> getPhotos() async {
var dbClient = await db;
List<Map> maps = await dbClient.query(TABLE, columns: [ID, NAME]);
List<SaveImage> employees = [];
if (maps.length > 0) {
for (int i = 0; i < maps.length; i++) {
employees.add(SaveImage.fromMap(maps[i]));
}
}
return employees;
}
Future close() async {
var dbClient = await db;
dbClient.close();
}
}

我已经使用图像选择器从库中提取转换为64进制字符串的图像,并将其保存在数据库中。

selectImages() async {
final List<XFile>? selectedImages = await _picker.pickMultiImage();
if (selectedImages!.isNotEmpty) {
_imageList.addAll(selectedImages);
}
for (var i = 0; i > _imageList.length; i++) {
try {
var bytes = Io.File(_imageList[i].path).readAsBytesSync();
String img64 = base64Encode(bytes);
SaveImage saveImage = SaveImage(id: i, image: img64);
dbHelper.save(saveImage);
} catch (e) {
print(e);
}
}
print("selected images are " + _imageList.length.toString());
if (images.isEmpty) {
print("no data");
} else {
print("data");
}
}

这是我的init状态方法和从db 检索数据的方法

@override
void initState() {
// TODO: implement initState
super.initState();
dbHelper = DBHelper();
images = [];
refreshImages();
print("length of image is " + images.length.toString());
}
refreshImages() async {
await dbHelper.getPhotos().then((value) {
images.addAll(value);
});
}

我无法将图像保存在数据库中,请帮助我

我认为您的配置中缺少一些部分:

_onCreate(Database db, int version) async {
await db.execute("CREATE TABLE $TABLE ($ID INTEGER, $NAME TEXT)");
}

应该是

Future<void> _onCreate(Database db, int version) async {
await db.execute('CREATE TABLE $TABLE ('
'$ID INTEGER PRIMARY KEY AUTOINCREMENT, '
'$NAME TEXT)');
}

完整的工作示例:

import 'package:flutter/material.dart';
import 'package:path_provider/path_provider.dart';
import 'package:sqflite/sqflite.dart';
import 'dart:io';

Future<void> main() async {
WidgetsFlutterBinding.ensureInitialized();
final dbHelper = DBHelper();
await dbHelper.initDb();
final bob = await dbHelper.save(Employee(name: 'Bob'));
final john = await dbHelper.save(Employee(name: 'John'));
final employees = await dbHelper.getEmployees();
print(bob);
print(john);
print(employees);
runApp(const MaterialApp(home: Text('app')));
}
class Employee {
const Employee({
this.id,
required this.name,
});
factory Employee.fromMap(Map<String, dynamic> map) {
final id = map['id'];
final name = map['name'];
if (name is! String) {
throw Exception('Employee name from database must be a String');
}
if (id is! int?) {
throw Exception('Employee id from database must be an integer');
}
return Employee(id: id, name: name);
}
final int? id;
final String name;
Employee copyWith({
int? id,
String? name,
}) {
return Employee(
id: id ?? this.id,
name: name ?? this.name,
);
}
Map<String, dynamic> toMap() => {'id': id, 'name': name};
@override
String toString() {
return toMap().toString();
}
}
class DBHelper {
static Database? _db;
static const String ID = 'id';
static const String NAME = 'name';
static const String TABLE = 'PhotosTable';
static const String DB_NAME = 'photos.db';
Future<Database> get db async {
if (null != _db) {
return _db!;
}
_db = await initDb();
return _db!;
}
Future<Database> initDb() async {
final documentsDirectory = await getApplicationDocumentsDirectory();
final path = '$documentsDirectory${Platform.pathSeparator}$DB_NAME';
return openDatabase(path, version: 1, onCreate: _onCreate);
}
Future<void> _onCreate(Database db, int version) async {
await db.execute('CREATE TABLE $TABLE ('
'$ID INTEGER PRIMARY KEY AUTOINCREMENT, '
'$NAME TEXT)');
}
Future<Employee> save(Employee employee) async {
final dbClient = await db;
final id = await dbClient.insert(TABLE, employee.toMap());
return employee.copyWith(id: id);
}
Future<List<Employee>> getEmployees() async {
final dbClient = await db;
final maps = await dbClient.query(TABLE, columns: [ID, NAME]);
final employees = <Employee>[];
if (maps.isNotEmpty) {
for (int i = 0; i < maps.length; i++) {
employees.add(Employee.fromMap(maps[i]));
}
}
return employees;
}
Future close() async {
final dbClient = await db;
dbClient.close();
}
}

最新更新