使用 NodeJs 将文本文件名保存到数据库

Question

我有一个问题，我需要你的帮助.. 是否可以创建一个应用程序，将所有.txt 放在一个目录中，然后将其文件名保存到数据库中，如果对文件名进行验证，则不会在数据库中保存两次。

我的代码在这里：

const path = require('path')

//mysql Connecion
var mysql = require('mysql');

var con = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "",
  database: "sms"
});

//con checking if the database is connected
con.connect(function(err) {
    if (err) throw err;

    //watchfile directory if there's new added file
    var chokidar = require('chokidar'); 
    var watcher = chokidar.watch('texts/', {ignored: /^\./, persistent: true});

    //for getting the filename only
    var fs = require('fs');
    var testFolder = 'texts/';

    watcher.on('add', function(filePath) {

        var filename = path.basename(filePath);

        var selectSql = 'SELECT count(*) FROM txtfilename WHERE filename="${filename}"';
        con.query(selectSql, (err, results, fields) => {
                // TODO: Catch the error
                var matchingEntriesCount = results

                if (matchingEntriesCount === 0) {
                    // TODO: Do your insert query
                    console.log('File', results, 'has been added');
                    var insertsql = "INSERT INTO txtfilename (filename) VALUES ('"+ results +"')";
                    con.query(insertsql, function (err, result) {
                        if (err) throw err;
                        console.log("1 record inserted");
                    });
                }
        });
    });
    watcher.on('unlink', function(path) {console.log('File', path, 'has been removed');});
});

我的代码现在可以读取将保存在目录中的所有文件，但我在 SELECT 和 INSERT 上遇到了问题。

我想使用 select 进行验证。为了不在数据库中插入相同的文件名。

最后是插入。我想插入每个将保存到目录的新文件名。

希望有人可以帮助我。

我只是 NodeJS 的新手

Answer 1

我看到的第一个问题是您只需要从观察者返回的path 中获取文件名。我将为此使用path 包basename 方法。

const path = require('path')

...

watcher.on('add', function(filePath) {
    var filename = path.basename(filePath);
    ....

然后您必须计算表中与此文件名匹配的条目。

    var selectSql = `SELECT count(*) AS matchingEntriesCount FROM txtfilename WHERE filename="${filename}"`

    con.query(selectSql, (err, results, fields) => {
        // TODO: Catch the error
        var matchingEntriesCount = results[0].matchingEntriesCount

        if (matchingEntriesCount === 0) {
            // TODO: Do your insert query
        }
    });
});