mirror of
				https://gitlab.com/comunic/comunicapiv2
				synced 2025-11-03 19:14:03 +00:00 
			
		
		
		
	Add connection to MySQL database
This commit is contained in:
		
							
								
								
									
										41
									
								
								src/helpers/DatabaseHelper.ts
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										41
									
								
								src/helpers/DatabaseHelper.ts
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,41 @@
 | 
			
		||||
import { createConnection, Connection } from "mysql";
 | 
			
		||||
import { conf } from "./ConfigHelper";
 | 
			
		||||
 | 
			
		||||
/**
 | 
			
		||||
 * Database helper
 | 
			
		||||
 * 
 | 
			
		||||
 * @author Pierre HUBERT
 | 
			
		||||
 */
 | 
			
		||||
 | 
			
		||||
export class DatabaseHelper {
 | 
			
		||||
 | 
			
		||||
	private static connection : Connection;
 | 
			
		||||
 | 
			
		||||
	/**
 | 
			
		||||
	 * Connect to database
 | 
			
		||||
	 */
 | 
			
		||||
	static async connect() {
 | 
			
		||||
		this.connection = createConnection({
 | 
			
		||||
			host: conf().database.host,
 | 
			
		||||
			user: conf().database.user,
 | 
			
		||||
			password: conf().database.password,
 | 
			
		||||
			database: conf().database.dbName
 | 
			
		||||
		});
 | 
			
		||||
 | 
			
		||||
		await new Promise((resolve, reject) => {
 | 
			
		||||
			this.connection.connect(err => {
 | 
			
		||||
 | 
			
		||||
				if(err) {
 | 
			
		||||
					console.error("Could not connect to database !");
 | 
			
		||||
					console.error(err);
 | 
			
		||||
					reject(err);
 | 
			
		||||
					return;
 | 
			
		||||
				}
 | 
			
		||||
 | 
			
		||||
				console.info("Connected to database.");
 | 
			
		||||
				resolve();
 | 
			
		||||
			});
 | 
			
		||||
		})
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
		Reference in New Issue
	
	Block a user