· 7 years ago · Feb 26, 2019, 11:42 PM
1var mysql = require('mysql');
2
3var connection = mysql.createConnection({
4 host: 'localhost',
5 port: 3306,
6 user: 'root',
7 password: '',
8 database: 'clientes'
9});
10
11connection.connect(function(err){
12 if(err) {
13 return console.log(err);
14 } else {
15 console.log("Conectado!");
16 createTable(connection);
17 }
18});
19
20function createTable(conn) {
21
22 var sql = "CREATE TABLE IF NOT EXISTS clientes (ID int NOT NULL AUTO_INCREMENT, Nome varchar(255), Email varchar(255), CPF char(11) NOT NULL, PRIMARY KEY(ID));";
23
24 conn.query(sql, function (error, results, fields) {
25 if(error) {
26 return console.log(error);
27 } else {
28 console.log("A tabela foi criada!");
29 addCliente(conn);
30 }
31 });
32
33}
34
35function addCliente(conn) {
36
37 var sql = "INSERT INTO clientes(Nome, Email, CPF) VALUES ?";
38 var valores = [
39 ['Andre', 'andre@test.com.br', '12345678901'],
40 ['Marcelo', 'marcelo@test.com.br', '12345678901']
41 ];
42 conn.query(sql, [valores], function (error, results, fields) {
43 if(error) {
44 return console.log(error);
45 } else {
46 console.log("Registros adicionados!");
47 exibirClientes(conn);
48 }
49 })
50
51}
52
53function exibirClientes(conn) {
54
55 var sql = "SELECT * FROM clientes";
56 conn.query(sql, function (error, results, fields) {
57 if(error) {
58 return console.log(error);
59 } else {
60 for(var i = 0; i < results.length; i ++) {
61 console.log(results[i].Nome);
62 }
63 }
64 });
65
66
67
68}