mariadbの導入

mariaDBを使用するためにmariadbをインストールする

npmの場合

npm install mariadb

yarnの場合

yarn add mariadb

javascriptでの記述

パッケージの読み込み

const mariadb = require('mariadb');

DTBへの接続するための設定処理

const pool = mariadb.createPool({
    host: 'localhost', 
    user: '',              //データーベースを操作するユーザー名を記述する
    password: '',          //操作するユーザーのパスワードを記述する
    database: '',          //操作するデーターベース名を記述
    // 同時接続数の制限（任意）をかけるために記述
    //connectionLimit: 5
});

データベースを操作する基本コード



pool.getConnection()
        .then(conn => {
            conn.query('データベースを操作するsql文を記述する場所')
                .then(results => {   //データーベースからデーターを取得できた場合の処理
                 
                })
                .catch(error => {   //データーベースの接続を失敗したときの処理
                    console.log(error);
                })
                .finally(() => { //最後に必ず行う処理
					//接続を終了する
					if(conn) conn.end();
				});

	}).catch((error: any) => {
		console.log(error);
	});

データベースから情報を取得する処理

app.get('/index', (req, res) => {

	pool.getConnection()
		.then(conn => {

			conn.query('SELECT * FROM items')
				.then(results => { //mysqlからデータを取得できた場合の処理

        			//itemsという変数に値を保持する
                     res.render('index.ejs', {items: results});

				})
				.then((error: any) => { //errorを取得したときの処理
					console.log(error);
				})
				.finally(() => { //最後に必ず行う処理
					//接続を終了する
    				if(conn) conn.end();
				});

    })
    .catch((error: any) => {
		console.log(error);
	});
});

データーベースへ情報を登録する処理

サイトの送信フォームからデータの送信コード


<form action="/create" method="post">
    <input type="text" name="itemName" />　<!---「itemName」と名前で値を送信する -->
    <input type="submit" value="作成する" />
</form>

データを受信するために必要な記述

データを送信してもurlエンコードを適切に解析できるようにしないとエラーを発して受信ができない。
パッケージの読み込みの後に記述

//記述することによりexpressアプリがurlエンコードされたデータを適切に解析できるようになる。
app.use(express.urlencoded({extended: false}));

データを受信し登録するコード

//[/new]でsubmitされた値をデーターベースへ登録する処理
app.post('/create',(req , res) => { //データを受け取るのでpostになる。

	//送信フォームか送られた値を受け取る変数
    //送信元はname="itemName"で送られてきたので
    //req.body」の後は「itemName」にしないと受信できない。
	const name = req.body.itemName;

	//SQL分を登録する変数
     //挿入のためのinsert分
	const query = `INSERT INTO items (name) VALUES ('${name}')`;

	pool.getConnection()
	.then( conn => {

		conn.query(query)
		.then(() => {		//データーを挿入出来たらindexページへ移動する

            //redirectでSQLへ２重登録を防いでいる
			res.redirect('/index');
		})
		.catch(error =>{	//挿入中にエラーが発生したらエラーを表示する
			console.error('データの挿入中にエラーが発生しました:',error);
			res.redirect('/index');
		})
    	.finally(() => {    //データーベースとの接続を切る処理
			if(conn) conn.end();
		});

	})
	.catch((error: any) => {
		console.error("MariaDBへの接続中にエラーが発生しました:", error);
	});
});

データを削除する処理

送信された値を受け取るわけではないので'req.body'ではなく'req.params'

//削除する処理
app.post('/delete/:id', (req:any, res:any) => {

    //削除したいデータ'/delete/:id'でアクセスされた':id'を受け取る
    //送信された値を受け取るわけではないので'req.body'ではなく'req.params'
	const id = req.params.id;

	const query = `DELETE FROM items WHERE id = '${id}'`;

	pool.getConnection()
	.then( conn => {

		conn.query(query)
		.then(() => {		//データーを削除出来たらindexページへ移動する

            //redirectでSQLへ２重処理を防いでいる
			res.redirect('/index');
		})
		.catch(error =>{	//削除中にエラーが発生したらエラーを表示する
			console.error('データの削除中にエラーが発生しました:',error);
			res.redirect('/index');
		})
    	.finally(() => {    //データーベースとの接続を切る処理
			if(conn) conn.end();
		});

	})
	.catch((error: any) => {
		console.error("MariaDBへの接続中にエラーが発生しました:", error);
	});
});