const db = require('sqlite3').verbose()
const path = require("path")
const fs = require("fs")
const {Sequelize} = require('sequelize');
import {localFilePath} from "@/config";
import {creatFolder, fileExistence} from "@/utils/file";
import writers from "@/db/writers/tables/writers";
export default class DbUtils {
// 所有要存放或者要读取的本地文件根路径
public localFilePath: string = localFilePath()
protected dbPathTem: string = '' // 临时的数据库文件路径
public readonly defaultFolder: string = 'dbFile'
constructor() {
this.setLocalFilePath()
}
public setLocalFilePath = (path: string = localFilePath()): void => {
this.localFilePath = path
}
/**
* @description 保存数据库文件
* @param {string} dbNameIsFullPath dbName是否完整路径,如果不是会自动拼接
* @param {string} dbName 数据库文件名称
* @param {string} folderName 存放的文件夹名称(默认dbs),如果没有则自动创建
* @return {string} 如果数据库已经存在,则返回路径,否则返回空字符串
*/
public createDbFile(dbNameIsFullPath: boolean = true, dbName: string = this.dbPathTem, folderName?: string): Promise<string> {
return new Promise((resolve, reject) => {
if (!this.judgeDbExists(dbNameIsFullPath, dbName, folderName)) {
const dbFile = new db.Database(this.dbPathTem, (err: any) => {
if (err) {
console.error('创建数据库失败=> ', err)
resolve('')
} else {
console.log(`创建数据库${dbName}成功`)
resolve(this.dbPathTem)
}
})
} else {
console.log(`数据库${dbName}已经存在`)
resolve(this.dbPathTem)
}
})
}
/**
* @description db文件路径
* @param {string} dbName
* @param {string} folderName 存放于哪个文件夹下,如果没有会自动创建
*/
public dbPath(dbName: string, folderName: string = this.defaultFolder): string {
return path.join(creatFolder(folderName), dbName + ".db")
}
/**
* @description 判断db文件是否存在, 并设置临时路径
* @param {boolean} dbNameIsFullPath dbName是否完整路径,如果不是会自动拼接
* @param {string} dbName
* @param {string} folderName 存放于哪个文件夹下,如果没有会自动创建
*/
public judgeDbExists(dbNameIsFullPath: boolean = true, dbName: string, folderName: string = this.defaultFolder): boolean {
this.dbPathTem = dbNameIsFullPath ? dbName : this.dbPath(dbName, folderName)
return fileExistence(true, this.dbPathTem)
}
/**
* @description db文件路径
* @param {boolean} dbNameIsFullPath dbName是否完整路径,如果不是会自动拼接
* @param {string} dbName 文件名
* @param {string} folderName 存放于哪个文件夹下,如果没有会自动创建
*/
public connectDb(dbNameIsFullPath: boolean = true, dbName: string = this.dbPathTem, folderName: string = this.defaultFolder): Promise<any> {
return new Promise((resolve, reject) => {
if (!this.judgeDbExists(dbNameIsFullPath, dbName, folderName)) {
console.error(`数据库${dbName}不存在,请先创建`)
resolve(false)
} else {
const dbInstance: any = new db.Database(this.dbPathTem, (err: any) => {
console.log(2)
if (err) {
console.error('连接数据库失败=> ', err)
resolve(false)
} else {
console.log('连接数据库成功', dbInstance)
resolve(dbInstance)
}
})
}
})
}
/**
* @description 自动创建并连接异步函数
* @param {boolean} dbNameIsFullPath dbName是否完整路径,如果不是会自动拼接
* @param {string} dbName 文件名
* @param {string} folderName 存放于哪个文件夹下,如果没有会自动创建
*/
public async creatAndConnectDb(dbNameIsFullPath: boolean, dbName: string, folderName: string = this.defaultFolder) {
if (!this.judgeDbExists(dbNameIsFullPath, dbName, folderName)) {
const res = await this.createDbFile()
}
return await this.connectDb()
}
/**
* @description 自动创建并连接异步函数-使用Sequelize工具
* @param {boolean} dbNameIsFullPath dbName是否完整路径,如果不是会自动拼接
* @param {string} dbName 文件名
* @param {string} folderName 存放于哪个文件夹下,如果没有会自动创建
*/
public async sequelizeOrm(dbNameIsFullPath: boolean, dbName: string, folderName: string = this.defaultFolder): Promise<boolean> {
if (!this.judgeDbExists(dbNameIsFullPath, dbName, folderName)) {
const res = await this.createDbFile()
if (!res) return false
}
try {
// 如果需要可以创建连接池 https://sequelize.org/docs/v6/other-topics/connection-pool/
const dataBase = await new Sequelize({
dialect: 'sqlite',
storage: this.dbPathTem
})
await dataBase.authenticate();
console.log('Connection has been established successfully. || 成功连接数据库!');
return dataBase
} catch (error) {
console.error('Unable to connect to the database:', error);
return false
}
}
// 创建连接多个表
public async createConnectTables(tables: any[], db:any){
return await Promise.all(tables.map(table => new Promise((resolve, reject) => resolve(db.define(table.name, table.data)))))
}
}
// export default new dbUtils()
export const localFilePath = (): string => __dirname.substring(0, __dirname.indexOf('resources') + 9)
import { localFilePath } from "@/config";
const fs = require("fs")
const path = require("path")
/**
* @description 创建文件夹
* @param {string} folderName 文件夹名
* @param {string} folderBeforePath 文件夹存放于哪个路径下
*/
export function creatFolder(folderName: string, folderBeforePath: string = localFilePath()) {
try {
const folderPath = path.join(folderBeforePath, folderName)
if(!fs.existsSync(path.join(localFilePath(), folderName))){
console.error(folderName + '文件夹不存在,正在创建...路径为 => \n', folderPath)
fs.mkdirSync(folderPath)
return folderPath
} else {
console.log(folderName + '文件夹已经存在,路径为=>', folderPath)
return folderPath
}
} catch (e) {
console.error('创建文件夹出错=>', e)
return false
}
}
// 创建文件
export function creatFile() {
}
/**
* @description 判断文件是否存在
* @param {string} fileNameIsFullPath fileName是否完整路径
* @param {string} fileName 文件名
* @param {string} folderName 存放于哪个文件夹或路径下
* @return { string } 如果文件存在,则返回路径,否则返回空字符串
*/
export function fileExistence(fileNameIsFullPath: boolean, fileName: string, folderName: string = ''): boolean {
try {
return fs.existsSync(fileNameIsFullPath ? fileName : path.join(localFilePath()), folderName, fileName)
} catch (e) {
console.error('检测文件是否存在出错=>', e)
return false
}
}
import DbUtils from "@/db/DbUtils";
const { Sequelize, Model, DataTypes } = require("sequelize");
import writers from "./tables/writers"
export default class Writer extends DbUtils{
private tableWriters: any
private tableTest: any
public dataBase: any
public constructor() {
super();
}
// 创建数据库、连接数据库、创建表
public async creatTable() {
const dataBase = await this.sequelizeOrm(false, 'writer')
// this.tableWriters = await dataBase.define(writers.name, writers.data); // 本来想这么写,可是总报错,就放弃了
const res = await this.createConnectTables([ writers], dataBase) // 其实这个封装没必要,封装了也可以,同时连接多个数据库
this.tableWriters = res[0]
// 将模型与数据库同步 参数文档 https://sequelize.org/api/v7/interfaces/syncoptions
await (async () => {
// @ts-ignore
await dataBase.sync({ force: false }); //当为true时,先删除表后再创建, 默认false
})();
this.dataBase = dataBase
return true
}
// 下面这些就可以直接调用了
public async insertWriter (content: string) {
const res = await this.tableWriters.create({ content: encodeURIComponent(content) });
res.save()
return res
}
public async getWriters () {
const res = await this.tableWriters.findAll();
return res
}
}
const { DataTypes } = require("sequelize");
// 如果后期需要新增字段需要手动定义migration(数据库迁移)。直接添加是不可行的
export default {
name: 'writers', // 表名
data: {
id: {
type: DataTypes.INTEGER, // INTEGER类型
primaryKey: true, // 主键
autoIncrement: true, // 自增长
},
content: {
type: DataTypes.TEXT,
allowNull : false
// defaultValue: '0', // 默认值
},
desc: {
type: DataTypes.TEXT, //
allowNull: true, // 不允许为空
defaultValue: '没有简介', // 默认值
},
// createTime: { // 自带
// type: DataTypes.STRING,
// allowNull : false
// },
// updateTime: { // 自带
// type: DataTypes.STRING,
// allowNull : false
// },
createArea: {
type: DataTypes.STRING,
allowNull : false,
defaultValue: '北京市', // 默认值
},
}
}
文章浏览阅读3.5k次,点赞2次,收藏13次。为了从FTP服务器下载文件,需要要实现一个简单的FTP客户端。FTP(文件传输协议) 是 TCP/IP 协议组中的应用层协议。FTP协议使用字符串格式命令字,每条命令都是一行字符串,以“\r\n”结尾。客户端发送格式是:命令+空格+参数+"\r\n"的格式服务器返回格式是以:状态码+空格+提示字符串+"\r\n"的格式,代码只要解析状态码就可以了。读写文件需要登陆服务器,特殊用..._ftp 登录返回230
文章浏览阅读648次。前提:systemctl stop firewalld 关闭防火墙关闭selinux查看getenforce临时关闭setenforce 0永久关闭sed-i'/SELINUX/s/enforcing/disabled/'/etc/selinux/configselinux的三种模式enforcing:强制模式,SELinux 运作中,且已经正确的开始限制..._centos7 安装rabbitmq3.6.5
文章浏览阅读5.8k次。满意答案s55f2avsx2017.09.05采纳率:46%等级:12已帮助:5646人新版Android Studio/IntelliJ IDEA可以直接导入eclipse项目,不再推荐使用eclipse导出gradle的方式2启动Android Studio/IntelliJ IDEA,选择 import project3选择eclipse 项目4选择 create project f..._android studio 项目导入idea 看不懂安卓项目
文章浏览阅读860次,点赞2次,收藏6次。AI大模型技术已经在自然语言处理、计算机视觉、多模态交互等领域取得了显著的进展和成果,同时也引发了一系列新的挑战和问题,如数据质量、计算效率、知识可解释性、安全可靠性等。城市运维涉及到多个方面,如交通管理、环境监测、公共安全、社会治理等,它们需要处理和分析大量的多模态数据,如图像、视频、语音、文本等,并根据不同的场景和需求,提供合适的决策和响应。知识搜索有多种形式,如语义搜索、对话搜索、图像搜索、视频搜索等,它们可以根据用户的输入和意图,从海量的数据源中检索出最相关的信息,并以友好的方式呈现给用户。_ai大模型应用开发
文章浏览阅读8.2k次,点赞12次,收藏121次。为什么要测量阻抗呢?阻抗能代表什么?阻抗测量的注意事项... ...很多人可能会带着一系列的问题来阅读本文。不管是数字电路工程师还是射频工程师,都在关注各类器件的阻抗,本文非常值得一读。全文13000多字,认真读完大概需要2小时。一、阻抗测试基本概念阻抗定义:阻抗是元器件或电路对周期的交流信号的总的反作用。AC 交流测试信号 (幅度和频率)。包括实部和虚部。图1 阻抗的定义阻抗是评测电路、元件以及制作元件材料的重要参数。那么什么是阻抗呢?让我们先来看一下阻抗的定义。首先阻抗是一个矢量。通常,阻抗是_阻抗实部和虚部
文章浏览阅读955次。前面章节分享试用了pyzero,pygame但随着想增加更丰富的游戏内容,好多还要进行自己编写类,从今天开始解绍一个新的python游戏库arcade模块。通过此次的《连连看》游戏实现,让我对swing的相关知识有了进一步的了解,对java这门语言也有了比以前更深刻的认识。java的一些基本语法,比如数据类型、运算符、程序流程控制和数组等,理解更加透彻。java最核心的核心就是面向对象思想,对于这一个概念,终于悟到了一些。_arcade语言 like
文章浏览阅读1.1k次。源码简介与安装说明:2021增强版短视频去水印源码 去水印微信小程序源码网站 去水印软件源码安装环境(需要材料):备案域名–服务器安装宝塔-安装 Nginx 或者 Apachephp5.6 以上-安装 sg11 插件小程序已自带解析接口,支持全网主流短视频平台,搭建好了就能用注:接口是公益的,那么多人用解析慢是肯定的,前段和后端源码已经打包,上传服务器之后在配置文件修改数据库密码。然后输入自己的域名,进入后台,创建小程序,输入自己的小程序配置即可安装说明:上传源码,修改data/_去水印机要增强版
文章浏览阅读557次。1. 触发器是FPGA存储数据的基本单元2. 触发器作为时序逻辑的基本元件,官方提供了丰富的配置方式,以适应各种可能的应用场景。_fdre #(.init(1'b0) // initial value of register (1'b0 or 1'b1) ) fdce_osc (
文章浏览阅读560次。本该是不同编译器结果不同,但是尝试了g++ msvc都是先计算c,再计算b,最后得到a+b+c是经过赋值以后的b和c参与计算而不是6。由上表可知,将q复制到p数组可以表示为:*p++=*q++,*优先级高,先取到对应q数组的值,然后两个++都是在后面,该行运算完后执行++。在电脑端编译完后会分为text data bss三种,其中text为可执行程序,data为初始化过的ro+rw变量,bss为未初始化或初始化为0变量。_嵌入式面试笔试c语言知识点
文章浏览阅读2.3k次。57 Things I've Learned Founding 3 Tech CompaniesJason Goldberg, Betashop | Oct. 29, 2010, 1:29 PMI’ve been founding andhelping run techn_mature
文章浏览阅读1.9k次。问题:先讲下需求,有若干个文本文件(txt或者csv文件等),每行代表一条数据,现在希望能合并成 1 个文本文件,且需要去除重复行。分析:一向奉行简单原则,如无必要,绝不复杂。如果数据量不大,那么如下两条命令就可以搞定合并:cat a.txt >> new.txtcat b.txt >> new.txt……去重:cat new...._python 超大文本合并
文章浏览阅读489次。这个过渡页是第一次打开小程序展示的,点击某个小程序前把手机的开发者->network link conditioner->enable & very bad network 就会在停在此页。比如《支付宝运动》这个小程序先看这个类的.h可以看到它继承于DTViewController点击左上角返回的方法- (void)back;#import "DTViewController.h"#import "APBaseLoadingV..._类似支付宝页面过度加载页