C#
VSCode
M1

C# 如何连接本地数据库？

1. 安装MySQL

下载MySQL软件，傻瓜式安装即可，安装完之后，在系统偏好号设置里会出现一个MySQL的图标。

在安装的时候会让用户输入密码，这个自己看着输就行了，但是别忘记了。

建议别用终端命令行安装了，对初学者来说学习成本比较大。

2. 连接本地MySQL

安装完MySQL之后，点击MySQL图标，开启MySQL，如下我已开启

我本地已安装了Navicate，我就使用Navicate对本地数据库进行连接，验证是否能连接成功

打开Nvicate点击Connection，选择MySQL

填入数据库名，输入密码连接就可以了

连接上之后可以创建一个数据库Test

然后我们在数据库Test里面创建表，之后就可以使用C# 连接到本地的数据库，对表Test进行操作了。

3. C# 连接本地MySQL

我们本地创建一个控制台命令程序Demo，然后完整代码如下

// 定义连接字符串。这里Test是我们创建的数据库表；Uid是一个表字段；输入数据库的密码即可
string connectStr = "Server=127.0.0.1;Database=Test.Uid=root;Password=xxx;";

// 创建链接对象
MySqlConnection connection = new MySqlConnection(connectStr);
if (connection != null) 
{
    Console.WriteLine("数据库连接成功");
}
else
{
    Console.WriteLine("数据库连接失败");
    return;
}

// 打开连接
connection.Open();

// 拼写SQL语句
StringBuilder sqlB = new StringBuilder();
sqlB.AppendLine("SELECT ");
sqlB.AppendLine("   stuID ");
sqlB.AppendLine(" , name ");
sqlB.AppendLine("FROM studen ");
sqlB.AppendLine("; ");

// 创建执行Sql的对象
MySqlCommand command = new MySqlCommand(sqlB.ToString(), connection);

// 执行Sql
MySqlDataReader reader = command.ExecuteReader();

// 遍历数据
while(reader.Read())
{
    Console.WriteLine("{0}\t{1}", reader["stuID"], reader["name"]);
}

上面的代码我们使用了 StringBuilder 来拼写Sql语句，使用MySqlConnection 和 MySqlCommand 等类进行数据库的操作

StringBuilder 是 System.Text 这个库里，我们需要Using这个库

MySqlConnection 和 MySqlCommand 是MySQL的一个库，MySql.Data，我们需要将 MySql.Data.MySqlClient 引入项目里

.net6 首选我们将库Using进来，在 .csproj 文件中添加 ItemGroup

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>net6.0</TargetFramework>
    <ImplicitUsings>enable</ImplicitUsings>
    <Nullable>enable</Nullable>
  </PropertyGroup>

  <ItemGroup>
    <Using Include="MySql.Data.MySqlClient" />
    <Using Include="System.Text" />
  </ItemGroup>

  <ItemGroup>
    <PackageReference Include="MySql.Data" Version="8.0.28" />
  </ItemGroup>

</Project>

因为我创建的是控制台应用程序，所以直接在终端中使用如下命令导入库

dotnet add package MySql.Data

➜  Demo dotnet add package MySql.Data
  正在确定要还原的项目…
  Writing /var/folders/k1/96lj0hk91js5fh5lhxnl7s740000gn/T/tmpn7jejh.tmp
info : 正在将包“MySql.Data”的 PackageReference 添加到项目“/Users/morris/Desktop/Demo/Demo.csproj”。
info :   CACHE https://api.nuget.org/v3/registration5-gz-semver2/mysql.data/index.json
info : 正在还原 /Users/morris/Desktop/Demo/Demo.csproj 的包...
info :   GET https://api.nuget.org/v3-flatcontainer/mysql.data/index.json
info :   OK https://api.nuget.org/v3-flatcontainer/mysql.data/index.json 217 毫秒
info :   GET https://api.nuget.org/v3-flatcontainer/mysql.data/8.0.28/mysql.data.8.0.28.nupkg
info :   OK https://api.nuget.org/v3-flatcontainer/mysql.data/8.0.28/mysql.data.8.0.28.nupkg 108 毫秒
info :   GET https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4.streams/index.json
info :   OK https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4.streams/index.json 196 毫秒
info :   GET https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4.streams/1.2.6/k4os.compression.lz4.streams.1.2.6.nupkg
info :   OK https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4.streams/1.2.6/k4os.compression.lz4.streams.1.2.6.nupkg 92 毫秒
info :   GET https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4/index.json
info :   OK https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4/index.json 233 毫秒
info :   GET https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4/1.2.6/k4os.compression.lz4.1.2.6.nupkg
info :   OK https://api.nuget.org/v3-flatcontainer/k4os.compression.lz4/1.2.6/k4os.compression.lz4.1.2.6.nupkg 93 毫秒
info : 已通过内容哈希 4EN8EE6bZG2U8dFfeqn+Om3UNajK3cPYHvyQROCFm4jNFVLuRB7Nl5bDkjBSAjfctS6konm+ay3u5RafBzltDA== 从 https://api.nuget.org/v3/index.json 安装 K4os.Compression.LZ4 1.2.6 。
info : 已通过内容哈希 5KMcNFRHeRrnJ9c8k5fZcfAJJEY0FndMiDiHIYa35Mx5KCMkeSNo/PEXu7YmtCoVczJagx+Vt7J/F+//S1PcJQ== 从 https://api.nuget.org/v3/index.json 安装 K4os.Compression.LZ4.Streams 1.2.6 。
info : 已通过内容哈希 7b699tU9ba0r7SBK7K9snGJB9ulnOdwEXG28kpVvaQSN0hHenfoJ/ADOtdfhcvcn1KStBX8pFK5qIl8scdBL2g== 从 https://api.nuget.org/v3/index.json 安装 MySql.Data 8.0.28 。
info : 包“MySql.Data”与项目“/Users/morris/Desktop/Demo/Demo.csproj”中指定的所有框架均兼容。
info : 包“MySql.Data”(版本为 8.0.28)的 PackageReference 已添加到文件“/Users/morris/Desktop/Demo/Demo.csproj”。
info : 将资产文件写入磁盘。路径: /Users/morris/Desktop/Demo/obj/project.assets.json
log  : 已还原 /Users/morris/Desktop/Demo/Demo.csproj (用时 3.6 sec)。

这个框架就会被下载引用到项目中了

最后执行 dotnet run , 数据库连接成功!

Flutter 本地数据库sqflite实战操作

通过本文章将带你了解sqflite如何使用并管理，注意要学习本功能、要具备一定的sql数据库操作的基础知识！

知识点：

• 本地化列表数据
• 本地化列表详情数据
• sqflite 本地化数据库增删改查操作

一、安装sqflite

https://pub.flutter-io.cn/packages/sqflite

二、创建Db数据库文件夹，创建Db文件

文件夹路径：Lib/Db/StepTasksDb/StepTasksDb.dart

三、编辑Db文件

StepTasksDb.dart全部代码

import 'package:path/path.dart';
import 'package:sqflite/sqflite.dart';

// 定义数据库Mock模型
final String tableName = 'step_task_table';                       // 数据库名称
final String columnId = '_id';                                    // 索引id
final String columnType = 'step_listType';                        // 列表类型
final String columnStepListData = 'step_listData';                // 列表数据
final String columnStepDataDetails = 'step_status';               // 列表详情数据


// 定义模板模型类
class StepTasks {
  int id;
  String stepListType;                                            // 列表类型
  String stepListData;                                            // 列表数据
  String stepDataDetails;                                         // 详情数据

  StepTasks({this.id, this.stepListType, this.stepListData, this.stepDataDetails});

  // 模型转Map数据使用
  Map<String, Object> toMap() {
    var map = <String ,Object>{
      columnType:stepListType,
      columnStepListData:stepListData,
      columnStepDataDetails:stepDataDetails
    };
    if (id != null) {
      map[columnId] = id;
    }
    return map;
  }

  // 模型数据传入类中
  StepTasks.fromMap(Map<String, Object> map){
    id = map[columnId];
    stepListType = map[columnType];
    stepListData = map[columnStepListData];
    stepDataDetails = map[columnStepDataDetails];
  }
}

// 定义数据库
class StepTasksDb {
  Database db;
  
  // 初始化数据库
  Future<String> initDatabase() async {
    // 获取本地存储数据库路径
    var databasesPath = await getDatabasesPath();
    // 创建数据库db文件
    String path = join(databasesPath, 'stepTasks.db');
    return path;
  }

  // 打开并创建表
  Future open(String path) async {
    print('------------------打开并创建表<StepTasksDb>------------------');
    db = await openDatabase(path, version:1, onCreate:(Database db, int version) async {
      await db.execute('''
        create table $tableName (
          $columnId integer primary key autoincrement,
          $columnType text ,
          $columnStepListData text ,
          $columnStepDataDetails text
        )
      ''');
    });
  }

  // 添加数据
  Future<StepTasks> insert(StepTasks data) async {
    data.id = await db.insert(tableName, data.toMap());
    return data;
  }

  // 获取数据(根据type条件查询)
  Future<List> getData({type = ''}) async {
    List<Map> maps = [];
    maps = await db.query(tableName, columns:[columnId, columnType, columnStepListData, columnStepDataDetails], where: '$columnType = ?', whereArgs: [type]);

    if(maps ==null || maps.length == 0){
      return [];
    }

    List list = [];

    for(int i = 0; i<maps.length; i++){
      list.add(maps[i]);
    }

    return list;
  }


  // 修改数据（通过id匹配修改整个数据）
  Future<int> update(StepTasks data) async {
    return await db.update(tableName, data.toMap(), where: '$columnId = ?', whereArgs: [data.id]);
  }

  // 删除数据（通过id匹配删除数据）
  Future<int> delete(int id) async {
    return await db.delete(tableName, where:'$columnId = ?', whereArgs:[id]);
  }

  // 关闭此表的链接
  Future close() async => db.close();
}

四、使用创建的数据库文件

注意：
首先安装网络监听插件：connectivity，虽然本插件已经停止更新了，但是在Pub官方文档也有新的插件替代了旧插件，大家可以凭个人需求来，这里不强求用什么插件，只需要达到网络监听效果即可。

import 'dart:convert';
import 'package:flutter/material.dart';
import 'TestDb_Flutter/Db/StepTasksDb/StepTasksDb.dart';

class TestDbPage extends StatefulWidget {

  @override
  State<TestDbPage> createState() => _TestDbPageState();
}

class _TestDbPageState extends State<TestDbPage> {

  var listData = [];
  var _storageListData = [];          // 存储本地数据
  List cacheSelectList = [];          // 存储需要缓存的数据
  var networkStatus = -1;			  // -1：没有网络 1：wifi  2：4G
  StepTasksDb _stepTaskDb = StepTasksDb();

  @override
  void initState() { 
    super.initState();
    _initDatabase();
  }
  
 // 打开数据库
  Future _initDatabase() async {
    String path = await _stepTaskDb.initDatabase();
    // await File(path).delete();       // 删除表
    await _stepTaskDb.open(path);       // 打开表
    _getListData();
  }

 // 网络请求数据
 Future _getListData() async {
 	await _getStorageData();
 	if(networkStatus == 1){
 		var res = await api.request('https://xxx.xxxx/api');
		setState((){listData = res['data']})
		return res;
 	}else{
 		// 没有网络的话
	    setState(() {
	      _listData = _storageListData;
	    });
	    return _storageListData;
 	}
	
 }

 // 获取本地数据
 Future _getStorageData() async {
    var data = await _stepTaskDb.getData(type: 'process');   
    setState(() {
      _storageListData = data;           // 先赋值一次 以便添加时使用
    });
  }
  
  @override
  void dispose() {
    // 关闭数据库
    _stepTaskDb.close();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return ListView.builder(
      itemCount: listData.length,
      itemBuilder: (context, index){
        return InkWell(
        	child:Container(child:Text(listData[index]['title']));
        	onTap:(){
        	      // 创建要存储本地的数据
        		  var dataBase = {
                    'step_listData': json.encode(listData[index]),
                  };
                  // 请求详情的参数
                  var params = {id:'xxx'};
                  var res = await api.request('https://xxx.xxxx/api', formData: params);
				  // 不为空的话，证明拿到了正常数据，将其存储到要存储的数据参数中
                  if(res != null){
                    dataBase['assets_listDetails'] = json.encode(res['data']);
                  }
        		  // 进行本地缓存
                  var db_res = await _stepTaskDb.insert(StepTasks(stepListType:'process', stepListData:dataBase['step_listData'], stepDataDetails:dataBase['assets_listDetails']));
        	},
        	onLongPress: (){
        			// 只在获取了本地存储的情况下，才能够通过id删除数据
	       	      _stepTaskDb.delete(v['_id']);
	      	},
        );
      },
    );
  }
}

以上代码暂且只介绍了本地化操作的 增删查操作、至于修改操作，则和增操作大体类似，通过传入的本地数据id，来将新的数据替换掉旧的数据即可

例子：

var res = await _stepTaskDb.update(StepTasks(id:v['id'], stepListType:'process', stepListData:dataBase['listData'], stepDataDetails:dataBase['listDetails']));

目前为止，应该将最基本的增删改查操作介绍完了，并且附上了例子，如果不出大问题的话，大家应该可以达到本地化数据的操作，有问题请下方留言联系我~

【前言】

上一节讲了本地日志，本地数据（文件）的部分，

详见：Electron那些事09：本地数据_uikoo9的博客-CSDN博客 

虽然本地日志可以记录日志信息，

本地数据可以记录简单的配置文件，

但是像一些复杂的业务，需要维护一个本地数据库进行查询，本节讲一下本地数据库sqlite

【sqlite】

sqlite是有名的本地数据库，在很多系统中都有应用，SQLite Home Page

当然也有nodejs的版本，一般配套和electron使用，sqlite3 - npm

默认的版本是nodejs版本，electron内可以直接使用，

还有node-webkit版本，这个版本是给node-webkit类环境使用，例如nw框架使用

另外还有sqlcipher版本，就是加密的本地数据库版本

【安装和使用】

安装比较简单

npm i sqlite3

先看官网一个例子

var sqlite3 = require('sqlite3').verbose();
var db = new sqlite3.Database(':memory:');

db.serialize(function() {
  db.run("CREATE TABLE lorem (info TEXT)");

  var stmt = db.prepare("INSERT INTO lorem VALUES (?)");
  for (var i = 0; i < 10; i++) {
      stmt.run("Ipsum " + i);
  }
  stmt.finalize();

  db.each("SELECT rowid AS id, info FROM lorem", function(err, row) {
      console.log(row.id + ": " + row.info);
  });
});

db.close();

 也比较简单，创建db，创建table，插入数据，然后查询，效果如下

【创建数据库】 

创建数据库的文档：https://github.com/mapbox/node-sqlite3/wiki/API#new-sqlite3databasefilename-mode-callback

filename，

当传入:memory:时，会将数据库保存在内存中，不会持久化

当传入具体的文件名时，会在对应的位置创建一个文件

例如直接传入test.db时，会在根目录下创建一个test.db文件

当传入具体的文件路径时，会在对应的路径下创建文件，

这样在electron应用下，就可以结合上一节的内容，将db文件创建在应用目录下了

【创建和更新表格】

创建数据库表也比较简单，使用sql创建即可，

db.run("CREATE TABLE lorem (info TEXT)");

 sqlite支持哪些数据类型呢，可以看这里，Datatypes In SQLite

可以需要注意，可以传入callback函数，如果创建失败，会报错，如果成功会返回null

    db.run(sql, (e) => {
        if(e) throw e;
    });

创建表格详细的文档可以看这里，CREATE TABLE 

更新表格可以看这里，ALTER TABLE

创建view，可以看这里，CREATE VIEW

删除表格和view，

DROP TABLE

https://www.sqlite.org/lang_dropview.html

【插入数据】

插入数据需要先使用db.prepare准备好statement语句，然后run，然后finalize写入，如下

详细可以看这里，INSERT 

【查询数据】 

查询数据，可以看这里，SELECT 

这里有三种返回数据的方法，all，each，get

all，返回所有数据

each，多次回调，返回每一个数据

get，返回第一个数据

// 多次回调
db.each('SELECT * FROM t_project', function(err, row) {
    console.log(row);
});

// 返回第一行
db.get('SELECT * FROM t_project', function(err, row) {
    console.log(row);
});

// 返回所有数据
db.all('SELECT * FROM t_project', function(err, row) {
    console.log(row);
});

【删除数据】

删除数据可以看这里，DELETE

【m1下问题】

sqlite3这个npm包，单独使用没有问题，

但是在mac m1+electron环境下使用会报错，如下

报错提示找不到arm64下的文件，但是sqlite3下有x64版本的，

修复的版本，npm i的时候添加指定系统

npm install --target_arch=arm64

 这样即可安装arm64版本的sqlite3

【qiao-sqlite】

将常见的sqlite操作封装了一个npm，qiao-sqlite - npm

create db

create table

drop table

 

 

show tables

以及常见的数据操作

insert data

modify data

get data

select data

del data

等操作 

【总结】

1.使用sqlite作为本地数据库

2.创建数据库

3.创建和修改表

4.插入数据，修改数据，查询数据，删除数据等