parent
71c20c8a06
commit
742330d6fe
@ -13,7 +13,7 @@ const access: ConnectionOptions = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
class MySqlHandler {
|
class MysqlHandler {
|
||||||
private readonly handlerName: string;
|
private readonly handlerName: string;
|
||||||
private Logger: Logger<unknown>
|
private Logger: Logger<unknown>
|
||||||
private Connection: Connection;
|
private Connection: Connection;
|
||||||
@ -81,9 +81,9 @@ class MySqlHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const MySqlService = {
|
const MySqlService = {
|
||||||
Handler : MySqlHandler,
|
Handler : MysqlHandler,
|
||||||
User: {
|
User: {
|
||||||
insert(handler: MySqlHandler, userData: DbUserData) {
|
insert(handler: MysqlHandler, userData: DbUserData) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _now = new Date()
|
const _now = new Date()
|
||||||
const _sql = "INSERT INTO `users`(`username`, `displayName`, `firstName`, `lastName`, `email`, `passwordHash`, `isAdmin`, `isDisabled`, `dob`, `gdpr`, `iat`, `uat`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
|
const _sql = "INSERT INTO `users`(`username`, `displayName`, `firstName`, `lastName`, `email`, `passwordHash`, `isAdmin`, `isDisabled`, `dob`, `gdpr`, `iat`, `uat`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
|
||||||
@ -109,7 +109,7 @@ const MySqlService = {
|
|||||||
})
|
})
|
||||||
},
|
},
|
||||||
|
|
||||||
update(handler: MySqlHandler, userData: DbUserData) {
|
update(handler: MysqlHandler, userData: DbUserData) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
|
|
||||||
//@ts-ignore
|
//@ts-ignore
|
||||||
@ -142,7 +142,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getById(handler: MySqlHandler, userId: string): Promise<DbUserData> {
|
getById(handler: MysqlHandler, userId: string): Promise<DbUserData> {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT * FROM `users` WHERE `id` = ?";
|
const _sql = "SELECT * FROM `users` WHERE `id` = ?";
|
||||||
const _values = [userId];
|
const _values = [userId];
|
||||||
@ -154,7 +154,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getAll(handler: MySqlHandler): Promise<Array<DbUserData>> {
|
getAll(handler: MysqlHandler): Promise<Array<DbUserData>> {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT * FROM `users`";
|
const _sql = "SELECT * FROM `users`";
|
||||||
try {
|
try {
|
||||||
@ -165,7 +165,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getByUsername(handler: MySqlHandler, username: string) {
|
getByUsername(handler: MysqlHandler, username: string) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT * FROM `users` WHERE `username` = ?";
|
const _sql = "SELECT * FROM `users` WHERE `username` = ?";
|
||||||
const _values = [username];
|
const _values = [username];
|
||||||
@ -177,7 +177,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getByEmail(handler: MySqlHandler, email: string) {
|
getByEmail(handler: MysqlHandler, email: string) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT * FROM `users` WHERE `email` = ?";
|
const _sql = "SELECT * FROM `users` WHERE `email` = ?";
|
||||||
const _values = [email];
|
const _values = [email];
|
||||||
@ -189,7 +189,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getByDisplayName(handler: MySqlHandler, displayName: string) {
|
getByDisplayName(handler: MysqlHandler, displayName: string) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT * FROM `users` WHERE `displayName` = ?";
|
const _sql = "SELECT * FROM `users` WHERE `displayName` = ?";
|
||||||
const _values = [displayName];
|
const _values = [displayName];
|
||||||
@ -201,7 +201,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getAdminStateForId(handler: MySqlHandler, userId: string) : Promise<boolean> {
|
getAdminStateForId(handler: MysqlHandler, userId: string) : Promise<boolean> {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "SELECT `isAdmin` FROM `users` WHERE `id` = ?";
|
const _sql = "SELECT `isAdmin` FROM `users` WHERE `id` = ?";
|
||||||
const _values = [userId];
|
const _values = [userId];
|
||||||
@ -217,7 +217,7 @@ const MySqlService = {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
delete(handler: MySqlHandler, userId: string) {
|
delete(handler: MysqlHandler, userId: string) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const _sql = "DELETE FROM `users` WHERE `id` = ?";
|
const _sql = "DELETE FROM `users` WHERE `id` = ?";
|
||||||
const _values = [userId];
|
const _values = [userId];
|
||||||
|
Loading…
x
Reference in New Issue
Block a user