Advertisement
Guest User

Untitled

a guest
Feb 27th, 2017
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.28 KB | None | 0 0
  1. var express = require('express');
  2. var path = require('path');
  3. var favicon = require('serve-favicon');
  4. var logger = require('morgan');
  5. var cookieParser = require('cookie-parser');
  6. var bodyParser = require('body-parser');
  7.  
  8. var index = require('./routes/index');
  9. var users = require('./routes/users');
  10. var mysql = require('mysql')
  11. var app = express();
  12. var users = require('./routes/users');
  13. var media = require('./routes/media');
  14. var tv = require('./routes/tv');
  15. var movies = require('./routes/movies');
  16. var db = require('./db')
  17.  
  18. var connection = mysql.createConnection({
  19. port: '3306',
  20. host: '*********************',
  21. user: '********',
  22. password: '******'
  23. })
  24.  
  25. db.connect(function(err) {
  26. if (err) {
  27. console.log('Unable to connect to MySQL.')
  28. process.exit(1)
  29. } else {
  30. console.log('Successfully connected')
  31. }
  32. })
  33.  
  34. app.use('/api', users);
  35.  
  36. var db = require('../db.js');
  37. var passwordHash = require('password-hash');
  38.  
  39.  
  40. exports.getAll = function(done) {
  41. db.get().query('SELECT * FROM users', function (err, rows) {
  42. if (err) return done(err)
  43. done(null, rows)
  44. })
  45. }
  46.  
  47. var express = require('express');
  48. var router = express.Router()
  49. var user = require('../models/user');
  50. var db = require('../db');
  51.  
  52. //this doesn't prInt anything currently. This is prompting me to believe I somehow
  53. //need to pass a connection object or am using the pool properly.
  54. console.log(db.get());
  55.  
  56. router.route('/users').get(function(req, res) {
  57. user.getAll(function(err, users) {
  58. if (err) {
  59. return res.send(err);
  60. }
  61. res.json(users);
  62. });
  63. });
  64.  
  65. var mysql = require('mysql')
  66. , async = require('async')
  67.  
  68. var PRODUCTION_DB = 'app_prod_database'
  69. , TEST_DB = 'app_test_database'
  70.  
  71. exports.MODE_TEST = 'mode_test'
  72. exports.MODE_PRODUCTION = 'mode_production'
  73.  
  74. var state = {
  75. pool: null,
  76. //mode: null,
  77. }
  78.  
  79. exports.connect = function(done) {
  80. state.pool = mysql.createPool({
  81. port: '3306',
  82. host: '***************',
  83. user: '*********',
  84. password: '*******'
  85. //database: mode === exports.MODE_PRODUCTION ? PRODUCTION_DB : TEST_DB
  86. })
  87.  
  88. //state.mode = mode
  89. done()
  90. }
  91.  
  92. exports.get = function() {
  93. return state.pool
  94. }
  95.  
  96. exports.fixtures = function(data) {
  97. var pool = state.pool
  98. if (!pool) return done(new Error('Missing database connection.'))
  99.  
  100. var names = Object.keys(data.tables)
  101. async.each(names, function(name, cb) {
  102. async.each(data.tables[name], function(row, cb) {
  103. var keys = Object.keys(row)
  104. , values = keys.map(function(key) { return "'" + row[key] + "'" })
  105.  
  106. pool.query('INSERT INTO ' + name + ' (' + keys.join(',') + ') VALUES (' + values.join(',') + ')', cb)
  107. }, cb)
  108. }, done)
  109. }
  110.  
  111. exports.drop = function(tables, done) {
  112. var pool = state.pool
  113. if (!pool) return done(new Error('Missing database connection.'))
  114.  
  115. async.each(tables, function(name, cb) {
  116. pool.query('DELETE * FROM ' + name, cb)
  117. }, done)
  118. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement