2017-05-12 5 views
0

とpostgresとsqlの間の単純な接続をしようとしていますが、私はモデルのフォルダを必要とすることはできませんが、私はモデルのフォルダを必要とすることができます同期には、model.syncのように、私は何をする必要があります。はsequelize

ので、これは私のアプリのコードです:

var express = require('express'); 
var path = require('path'); 
var favicon = require('serve-favicon'); 
var logger = require('morgan'); 
var cookieParser = require('cookie-parser'); 
var bodyParser = require('body-parser'); 
var debug = require('debug')('express-sequelize'); 
var http = require('http'); 
var model= require('./models'); 


var users = require('./routes/users'); 

var app = express(); 

// view engine setup 
app.set('views', path.join(__dirname, 'views')); 
app.set('view engine', 'jade'); 

// uncomment after placing your favicon in /public 
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico'))); 
app.use(logger('dev')); 
app.use(bodyParser.json()); 
app.use(bodyParser.urlencoded({ extended: false })); 
app.use(cookieParser()); 
app.use(express.static(path.join(__dirname, 'public'))); 

app.use('/users', users); 

// catch 404 and forward to error handler 
app.use(function(req, res, next) { 
    var err = new Error('Not Found'); 
    err.status = 404; 
    next(err); 
}); 

// error handler 
app.use(function(err, req, res, next) { 
    // set locals, only providing error in development 
    res.locals.message = err.message; 
    res.locals.error = req.app.get('env') === 'development' ? err : {}; 

    // render the error page 
    res.status(err.status || 500); 
    res.render('error'); 
}); 

/** 
* Get port from environment and store in Express. 
*/ 

var port = normalizePort(process.env.PORT || '3000'); 
app.set('port', port); 
    /** 
    * Create HTTP server. 
    */ 
var server = http.createServer(app); 

model.sequelize.sync().then(function() { 
    /** 
    * Listen on provided port, on all network interfaces. 
    */ 
    server.listen(port, function() { 
    debug('Express server listening on port ' + server.address().port); 
    }); 
    server.on('error', onError); 
    server.on('listening', onListening); 
}); 

/** 
* Normalize a port into a number, string, or false. 
*/ 

function normalizePort(val) { 
    var port = parseInt(val, 10); 

    if (isNaN(port)) { 
    // named pipe 
    return val; 
    } 

    if (port >= 0) { 
    // port number 
    return port; 
    } 

    return false; 
} 

/** 
* Event listener for HTTP server "error" event. 
*/ 

function onError(error) { 
    if (error.syscall !== 'listen') { 
    throw error; 
    } 

    var bind = typeof port === 'string' 
    ? 'Pipe ' + port 
    : 'Port ' + port; 

    // handle specific listen errors with friendly messages 
    switch (error.code) { 
    case 'EACCES': 
     console.error(bind + ' requires elevated privileges'); 
     process.exit(1); 
     break; 
    case 'EADDRINUSE': 
     console.error(bind + ' is already in use'); 
     process.exit(1); 
     break; 
    default: 
     throw error; 
    } 
} 

/** 
* Event listener for HTTP server "listening" event. 
*/ 

function onListening() { 
    var addr = server.address(); 
    var bind = typeof addr === 'string' 
    ? 'pipe ' + addr 
    : 'port ' + addr.port; 
    debug('Listening on ' + bind); 
} 

私のモデルsequelizeコード:

"use strict"; 

var fs  = require("fs"); 
var path  = require("path"); 
var Sequelize = require("sequelize"); 
var env  = process.env.NODE_ENV || "development"; 
var config = require(path.join(__dirname, '..','config', 'config.json'))[env]; 


if (process.env.DATABASE_URL) { 
    var sequelize = new Sequelize(process.env.DATABASE_URL,config); 
} else { 
    var sequelize = new Sequelize(config.database, config.username, config.password, config); 
} 
var db  = {}; 

fs 
    .readdirSync(__dirname) 
    .filter(function(file) { 
    return (file.indexOf('.') !== 0 && file.indexOf('sequelize.js') < 0); 
    }) 
    .forEach(function(file) { 
    var model = sequelize.import(path.join(__dirname, file)); 
    db[model.name] = model; 
    }); 

Object.keys(db).forEach(function(modelName) { 
    if ("associate" in db[modelName]) { 
    db[modelName].associate(db); 
    } 
}); 

db.sequelize = sequelize; 
db.Sequelize = Sequelize; 

module.exports = db; 

私のフォルダ構造:あなたは、あなたのモデル/ sequelize.jsの名前を変更する必要が folderStructure

答えて

2

モデルフォルダをモジュールとして必要とすることができるmodels/index.js。

+0

なぜですか?私は実際にプロジェクトを稼働させるためにそれをしましたが、続編の名前はそれが可能ではないのが本当に好きですか? –

+1

これは、nodejsがrequire()呼び出しをどのように処理するかに関連しています。 あなたの例では、あなたは持っています:var model = require( './ models'); ノードの意味は何ですか? まず、 "models.js"という名前のファイルを探します。そのようなファイルがないので、手順2に進み、 'models'という名前のフォルダと 'index.js'という名前のファイルが検索されます。 存在する場合は、require( './ models/index.js')と書いたようにする必要があります。 名前を付けたい場合は、require()コールを次のように変更する必要があります:var models = require( './ models/sequelize'); –

+1

しかし、あなたのモジュールがいくつかのファイルで構成されている場合、慣習的に 'loader'として使われるindex.jsを使うことを提案します。 –