Merge pull request 'order by' (#23) from dev into main

Reviewed-on: #23

.gitignore

@@ -2,3 +2,5 @@ dist
 node_modules
 ltests
 sqlsave
+postgresHandler.ts
+.vscode

.npmignore

@@ -1,2 +1,3 @@
 test.ts
 ltests
+sqlsave

.woodpecker.yml

@@ -10,9 +10,13 @@ pipeline:
       - npm install git+https://jusax.de/git/jusax23/gitea-release.git
       - mkdir build
       - mkdir dblang
+      - mkdir dblang/dist
       - mkdir upload
       - npm run prepublish
-      - cp dist/* dblang
+      - cp dist/* dblang/dist
+      - cp package.json dblang
+      - cp package-lock.json dblang
+      - cp readme.md dblang
       - zip -r upload/DBlang.zip dblang/*
       - tar -czvf upload/DBlang.tar.gz dblang/*
       - npx gitea-release "https://jusax.de/git/api/v1/" "$${GITEA_TOKEN}" "$${CI_REPO}" "$${CI_COMMIT_BRANCH}" "$${CI_COMMIT_TAG}" "upload" "$${CI_COMMIT_MESSAGE}"

package-lock.json

@@ -1,23 +1,25 @@
 {
   "name": "dblang",
-  "version": "1.0.0",
+  "version": "0.9.6",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "dblang",
-      "version": "1.0.0",
+      "version": "0.9.6",
       "license": "UNLICENSED",
       "dependencies": {
-        "mariadb": "^3.0.2"
+        "mariadb": "^3.0.2",
+        "pg": "^8.9.0"
       },
       "devDependencies": {
         "@types/node": "^18.11.18",
+        "@types/pg": "^8.6.6",
         "esbuild": "^0.17.4",
         "typescript": "^4.9.4"
       },
       "engines": {
-        "node": ">= 14"
+        "node": ">= 16"
       }
     },
     "node_modules/@esbuild/android-arm": {
@@ -383,6 +385,25 @@
       "integrity": "sha512-DHQpWGjyQKSHj3ebjFI/wRKcqQcdR+MoFBygntYOZytCqNfkd2ZC4ARDJ2DQqhjH5p85Nnd3jhUJIXrszFX/JA==",
       "dev": true
     },
+    "node_modules/@types/pg": {
+      "version": "8.6.6",
+      "resolved": "https://registry.npmjs.org/@types/pg/-/pg-8.6.6.tgz",
+      "integrity": "sha512-O2xNmXebtwVekJDD+02udOncjVcMZQuTEQEMpKJ0ZRf5E7/9JJX3izhKUcUifBkyKpljyUM6BTgy2trmviKlpw==",
+      "dev": true,
+      "dependencies": {
+        "@types/node": "*",
+        "pg-protocol": "*",
+        "pg-types": "^2.2.0"
+      }
+    },
+    "node_modules/buffer-writer": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/buffer-writer/-/buffer-writer-2.0.0.tgz",
+      "integrity": "sha512-a7ZpuTZU1TRtnwyCNW3I5dc0wWNC3VR9S++Ewyk2HHZdrO3CQJqSpd+95Us590V6AL7JqUAH2IwZ/398PmNFgw==",
+      "engines": {
+        "node": ">=4"
+      }
+    },
     "node_modules/denque": {
       "version": "2.1.0",
       "resolved": "https://registry.npmjs.org/denque/-/denque-2.1.0.tgz",
@@ -487,11 +508,133 @@
         "node": "*"
       }
     },
+    "node_modules/packet-reader": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/packet-reader/-/packet-reader-1.0.0.tgz",
+      "integrity": "sha512-HAKu/fG3HpHFO0AA8WE8q2g+gBJaZ9MG7fcKk+IJPLTGAD6Psw4443l+9DGRbOIh3/aXr7Phy0TjilYivJo5XQ=="
+    },
+    "node_modules/pg": {
+      "version": "8.9.0",
+      "resolved": "https://registry.npmjs.org/pg/-/pg-8.9.0.tgz",
+      "integrity": "sha512-ZJM+qkEbtOHRuXjmvBtOgNOXOtLSbxiMiUVMgE4rV6Zwocy03RicCVvDXgx8l4Biwo8/qORUnEqn2fdQzV7KCg==",
+      "dependencies": {
+        "buffer-writer": "2.0.0",
+        "packet-reader": "1.0.0",
+        "pg-connection-string": "^2.5.0",
+        "pg-pool": "^3.5.2",
+        "pg-protocol": "^1.6.0",
+        "pg-types": "^2.1.0",
+        "pgpass": "1.x"
+      },
+      "engines": {
+        "node": ">= 8.0.0"
+      },
+      "peerDependencies": {
+        "pg-native": ">=3.0.1"
+      },
+      "peerDependenciesMeta": {
+        "pg-native": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/pg-connection-string": {
+      "version": "2.5.0",
+      "resolved": "https://registry.npmjs.org/pg-connection-string/-/pg-connection-string-2.5.0.tgz",
+      "integrity": "sha512-r5o/V/ORTA6TmUnyWZR9nCj1klXCO2CEKNRlVuJptZe85QuhFayC7WeMic7ndayT5IRIR0S0xFxFi2ousartlQ=="
+    },
+    "node_modules/pg-int8": {
+      "version": "1.0.1",
+      "resolved": "https://registry.npmjs.org/pg-int8/-/pg-int8-1.0.1.tgz",
+      "integrity": "sha512-WCtabS6t3c8SkpDBUlb1kjOs7l66xsGdKpIPZsg4wR+B3+u9UAum2odSsF9tnvxg80h4ZxLWMy4pRjOsFIqQpw==",
+      "engines": {
+        "node": ">=4.0.0"
+      }
+    },
+    "node_modules/pg-pool": {
+      "version": "3.5.2",
+      "resolved": "https://registry.npmjs.org/pg-pool/-/pg-pool-3.5.2.tgz",
+      "integrity": "sha512-His3Fh17Z4eg7oANLob6ZvH8xIVen3phEZh2QuyrIl4dQSDVEabNducv6ysROKpDNPSD+12tONZVWfSgMvDD9w==",
+      "peerDependencies": {
+        "pg": ">=8.0"
+      }
+    },
+    "node_modules/pg-protocol": {
+      "version": "1.6.0",
+      "resolved": "https://registry.npmjs.org/pg-protocol/-/pg-protocol-1.6.0.tgz",
+      "integrity": "sha512-M+PDm637OY5WM307051+bsDia5Xej6d9IR4GwJse1qA1DIhiKlksvrneZOYQq42OM+spubpcNYEo2FcKQrDk+Q=="
+    },
+    "node_modules/pg-types": {
+      "version": "2.2.0",
+      "resolved": "https://registry.npmjs.org/pg-types/-/pg-types-2.2.0.tgz",
+      "integrity": "sha512-qTAAlrEsl8s4OiEQY69wDvcMIdQN6wdz5ojQiOy6YRMuynxenON0O5oCpJI6lshc6scgAY8qvJ2On/p+CXY0GA==",
+      "dependencies": {
+        "pg-int8": "1.0.1",
+        "postgres-array": "~2.0.0",
+        "postgres-bytea": "~1.0.0",
+        "postgres-date": "~1.0.4",
+        "postgres-interval": "^1.1.0"
+      },
+      "engines": {
+        "node": ">=4"
+      }
+    },
+    "node_modules/pgpass": {
+      "version": "1.0.5",
+      "resolved": "https://registry.npmjs.org/pgpass/-/pgpass-1.0.5.tgz",
+      "integrity": "sha512-FdW9r/jQZhSeohs1Z3sI1yxFQNFvMcnmfuj4WBMUTxOrAyLMaTcE1aAMBiTlbMNaXvBCQuVi0R7hd8udDSP7ug==",
+      "dependencies": {
+        "split2": "^4.1.0"
+      }
+    },
+    "node_modules/postgres-array": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/postgres-array/-/postgres-array-2.0.0.tgz",
+      "integrity": "sha512-VpZrUqU5A69eQyW2c5CA1jtLecCsN2U/bD6VilrFDWq5+5UIEVO7nazS3TEcHf1zuPYO/sqGvUvW62g86RXZuA==",
+      "engines": {
+        "node": ">=4"
+      }
+    },
+    "node_modules/postgres-bytea": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/postgres-bytea/-/postgres-bytea-1.0.0.tgz",
+      "integrity": "sha512-xy3pmLuQqRBZBXDULy7KbaitYqLcmxigw14Q5sj8QBVLqEwXfeybIKVWiqAXTlcvdvb0+xkOtDbfQMOf4lST1w==",
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
+    "node_modules/postgres-date": {
+      "version": "1.0.7",
+      "resolved": "https://registry.npmjs.org/postgres-date/-/postgres-date-1.0.7.tgz",
+      "integrity": "sha512-suDmjLVQg78nMK2UZ454hAG+OAW+HQPZ6n++TNDUX+L0+uUlLywnoxJKDou51Zm+zTCjrCl0Nq6J9C5hP9vK/Q==",
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
+    "node_modules/postgres-interval": {
+      "version": "1.2.0",
+      "resolved": "https://registry.npmjs.org/postgres-interval/-/postgres-interval-1.2.0.tgz",
+      "integrity": "sha512-9ZhXKM/rw350N1ovuWHbGxnGh/SNJ4cnxHiM0rxE4VN41wsg8P8zWn9hv/buK00RP4WvlOyr/RBDiptyxVbkZQ==",
+      "dependencies": {
+        "xtend": "^4.0.0"
+      },
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
     "node_modules/safer-buffer": {
       "version": "2.1.2",
       "resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
       "integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg=="
     },
+    "node_modules/split2": {
+      "version": "4.1.0",
+      "resolved": "https://registry.npmjs.org/split2/-/split2-4.1.0.tgz",
+      "integrity": "sha512-VBiJxFkxiXRlUIeyMQi8s4hgvKCSjtknJv/LVYbrgALPwf5zSKmEwV9Lst25AkvMDnvxODugjdl6KZgwKM1WYQ==",
+      "engines": {
+        "node": ">= 10.x"
+      }
+    },
     "node_modules/typescript": {
       "version": "4.9.4",
       "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.9.4.tgz",
@@ -504,6 +647,14 @@
       "engines": {
         "node": ">=4.2.0"
       }
+    },
+    "node_modules/xtend": {
+      "version": "4.0.2",
+      "resolved": "https://registry.npmjs.org/xtend/-/xtend-4.0.2.tgz",
+      "integrity": "sha512-LKYU1iAXJXUgAXn9URjiu+MWhyUXHsvfp7mcuYm9dSUKK0/CjtrUwFAxD82/mCWbtLsGjFIad0wIsod4zrTAEQ==",
+      "engines": {
+        "node": ">=0.4"
+      }
     }
   }
 }

package.json

@@ -1,15 +1,15 @@
 {
   "name": "dblang",
-  "version": "1.0.0",
+  "version": "0.9.6",
   "description": "",
   "main": "dist/db.js",
   "types": "dist/db.d.ts",
-  "type": "commonjs",
+  "type": "module",
   "directories": {
-    "dsit": "dist"
+    "dist": "dist"
   },
   "files": [
-    "dist"
+    "dist/*"
   ],
   "private": false,
   "scripts": {
@@ -18,13 +18,15 @@
   "author": "jusax23",
   "license": "UNLICENSED",
   "dependencies": {
-    "mariadb": "^3.0.2"
+    "mariadb": "^3.0.2",
+    "pg": "^8.9.0"
   },
   "engines": {
-    "node": ">= 14"
+    "node": ">= 16"
   },
   "devDependencies": {
     "@types/node": "^18.11.18",
+    "@types/pg": "^8.6.6",
     "esbuild": "^0.17.4",
     "typescript": "^4.9.4"
   }

readme.md

@@ -4,14 +4,17 @@
 
 TypeScript Libary for relational Database Requests. Requests are written in js/ts and it supports automatic Schema evulution.
 
-Fetures
+Features:
 - [x] select Query
 - [x] insert Query
 - [x] update Query
 - [x] remove Query
 - [x] create Schema
 - [x] remove unused Schema
-- [ ] joins
+- [x] joins
+- [x] table alias
+- [x] general aliases
+- [x] unified response
 - [ ] change Schema
 - [ ] Key-Value Store Shortcut
 - [ ] Views
@@ -27,7 +30,8 @@ Supported Databses:
 
 ```javascript
 import { DB } from "dblang";
-const db = new DB({
+const db = new DB();
+db.connect({
     host: "localhost",
     user: "root",
     password: "0123456789",
@@ -101,6 +105,46 @@ let res = await select([Table2.AttrName2], Table1)
     .having(le(Table2.AttrName3, 5)) //optional
     .limit(10) //optional
     .query(db);
+```
+
+_Joins_:
+```javascript
+import { INT, onAction } from "dblang"
+
+const TableA = db.newTable("TableA");
+const TableB = db.newTable("TableB");
+TableA.addAttribute("A1", INT, {
+    primaryKey: true
+});
+TableB.addAttribute("B1", INT, {
+    primaryKey: true,
+    foreignKey:{
+        link: TableA.A1,
+        onDelete: onAction.cascade
+    }
+});
+let res = await select([TableA.A1, TableB.B1], innerJoinOn(eq(TableA.A1, Tableb.B1)))
+    .query(db);
+```
+See: [Joins](#joins)
+
+_Aliases_:
+```javascript 
+const alias1 = TableA.createAlias("alias1");
+//alias1 can be used like a Table in select Statements.
+const alias2 = alias(avg(TableA.A1), "someAvg");
+```
+
+Get requestet Data:
+```javascript
+let response = await select([TableA.A1, TableB.B1], innerJoinOn(eq(TableA.A1, Tableb.B1)))
+    .query(db);
+
+response[0][TableA.A1];
+response[0][TableB.B1];
+
+response[i][TableA.A1];
+response[i][TableB.B1]; // i < repsonse.length
 
 ```
 
@@ -121,6 +165,8 @@ await insert(Table2.AttrName2, Table2.AttrName3)
 
 #### Update:
 ```javascript
+import { update } from "dblang"
+
 await update(Table2)
     .set(Table2.AttrName2, plus(Table2.AttrName2,1))
     .set(Table2.AttrName3, minus(Table2.AttrName2,1))
@@ -130,6 +176,8 @@ await update(Table2)
 
 #### Remove:
 ```javascript
+import { remove } from "dblang"
+
 await remove(Table2)
     .where(geq(Table2.AttrName2, 5))
     .query(db);
@@ -193,6 +241,7 @@ BooleanModifier:
 - `le(v1, v2, ...)`
 - `not(v1)`
 - `like(v1, v2)`
+- `exists(s)`
 
 NumberModifier:
 - `plus(v1, v2, ...)`
@@ -203,9 +252,27 @@ NumberModifier:
 StringModifier:
 - `concat(v1, v2, ...)`
 
-(v\* = string, number, boolean, null, Modifier, Aggregation, select Query, Attribute)
+(v\* = string, number, boolean, null, Modifier, Aggregation, select Query, Attribute; s = selectQuery)
 
-# Aggregations
+#### Joins
+
+- `crossJoin(t1, t2, ...)`
+- `naturalJoin(t1, t2, ...)`
+- `leftNaturalJoin(t1, t2, ...)`
+- `rightNaturalJoin(t1, t2, ...)`
+- `fullNaturalJoin(t1, t2, ...)`
+- `innerJoinUsing(t1, t2, a1, a2, ...)`
+- `leftJoinUsing(t1, t2, a1, a2, ...)`
+- `rightJoinUsing(t1, t2, a1, a2, ...)`
+- `fullJoinUsing(t1, t2, a1, a2, ...)`
+- `innerJoinOn(t1, t2, b)`
+- `leftJoinOn(t1, t2, b)`
+- `rightJoinOn(t1, t2, b)`
+- `fullJoinOn(t1, t2, b)`
+
+(t\* = Table or Join; a\* = Attributes; b = Boolean Modifier)
+
+#### Aggregations
 - `count(a)`
 - `sum(a)`
 - `avg(a)`

src/alias.ts

@@ -0,0 +1,90 @@
+import { Attribute, DB, Table } from "./db.js"
+import { Aggregation, Modifier } from "./dbStructure.js";
+import { Handler } from "./defaultHandler.js";
+import { QueryBuilder, selectQuery } from "./query.js";
+import { selectElements } from "./types.js";
+
+export class AttributeAlias {
+    name: string;
+    nameO: string;
+    table: TableAlias;
+    attr: Attribute;
+    constructor(attr: Attribute, table: TableAlias) {
+        this.name = attr.name;
+        this.nameO = attr.nameO;
+        this.attr = attr;
+        this.table = table;
+    }
+    serialize(handler: Handler) {
+        return handler.builders.escapeID(this.name);
+    }
+    getString(handler: Handler = this.table.dbLangDatabaseInstance.getHandler()) {
+        return this.table.serialize(handler) + "." + this.serialize(handler);
+    }
+    getStringFunc(handler: Handler) {
+        return this.table.serialize(handler) + "(" + this.serialize(handler) + ")";
+    }
+    toString() {
+        return this.table.dbLangTableName + "_" + this.name;
+    }
+}
+
+export class TableAlias {
+    dbLangTableName: string;
+    dbLangTableAttributes: { [key: string]: AttributeAlias; } = {};
+    dbLangDatabaseInstance: DB;
+    dbLangTableInstance: Table;
+    [key: string]: AttributeAlias | any;
+    constructor(name: string, table: Table) {
+        this.dbLangTableName = name;
+        this.dbLangTableInstance = table;
+        this.dbLangDatabaseInstance = table.dbLangDatabaseInstance;
+        let keys = Object.keys(table.dbLangTableAttributes);
+        for (let i = 0; i < keys.length; i++) {
+            const a = table.dbLangTableAttributes[keys[i]];
+            let attrAlias = new AttributeAlias(a, this);
+            this[a.name] = attrAlias;
+            this[a.nameO] = attrAlias;
+            this.dbLangTableAttributes[a.name] = attrAlias;
+        }
+    }
+    serializeAlias(hander: Handler) {
+        return this.dbLangTableInstance.serialize(hander) + " " + this.toString(hander);
+    }
+    serialize(handler: Handler) {
+        return this.toString(handler);
+    }
+    toString(handler: Handler = this.dbLangDatabaseInstance.getHandler()) {
+        return handler.builders.escapeID(this.dbLangTableName);
+    }
+}
+
+export class Alias {
+    alias: string;
+    a: selectElements;
+
+    constructor(a: selectElements, alias: string) {
+        this.alias = alias;
+        this.a = a;
+    }
+
+    serialize(handler: Handler) {
+        let builder = new QueryBuilder();
+        if (this.a instanceof Attribute || this.a instanceof AttributeAlias)
+            builder.addCode(this.a.getString(handler) + " " + handler.builders.escapeID(this.a.toString()));
+        else if (this.a instanceof Modifier || this.a instanceof selectQuery || this.a instanceof Aggregation || this.a instanceof Alias) {
+            builder.addCode("(");
+            builder.append(this.a.serialize(handler));
+            builder.addCode(")");
+        } else {
+            builder.addInjection(this.a);
+        }
+        return builder;
+    }
+    getString(handler: Handler) {
+        return this.serialize(handler);
+    }
+    toString() {
+        return this.alias;
+    }
+}

src/db.ts

@@ -1,34 +1,63 @@
 import mariadb from 'mariadb';
-import { checkConstraint, Constraint, Datatype, foreignConstraint, uniqueConstraint } from './dbStructure';
-import { Handler } from './defaultHandler';
-import { Query } from './query';
-import { attributeSettings, extendedAttributeSettings, onAction } from './types';
+import { checkConstraint, Constraint, Datatype, foreignConstraint, uniqueConstraint } from './dbStructure.js';
+import { Handler } from './defaultHandler.js';
+import { Query } from './query.js';
+import { attributeSettings, extendedAttributeSettings, onAction, dbType, order } from './types.js';
+import { TableAlias } from "./alias.js"
+import { insertResponse, readResponse, writeResponse, singleResponse } from "./responses.js"
+//import { postgresHandler } from "./postgresHandler"
 
+declare module "mariadb" {
+    interface Pool{
+        on(ev: 'error', callback: () => void): Pool;
+    }
+}
 
 export class DB {
     tables: Table[] = [];
-    handler: Handler;
-    name: string;
-    pool: mariadb.Pool;
-    constructor({ host, user, password, database, connectionLimit = 5 }: { host: string, user: string, password: string, database: string, connectionLimit: number }) {
-        this.pool = mariadb.createPool({ host, user, password, database, connectionLimit, multipleStatements: true });
-        this.handler = new Handler();
+    handler!: Handler;
+    name!: string;
+    type!: dbType;
+    mariaPool!: mariadb.Pool;
+    private connected = false;
+    //pgPool!: pg.Pool;
+    connect({ host, user, password, database, port = 3306, connectionLimit = 5, databaseType = dbType.mariadb }: { host: string, user: string, password: string, database: string, port?: number, connectionLimit?: number, databaseType?: dbType }) {
+        this.connected = true;
+        this.type = databaseType;
+        if (databaseType == dbType.mariadb) {
+            this.mariaPool = mariadb.createPool({ host, user, password, port, database, connectionLimit, multipleStatements: true });
+            // catch errors
+            this.mariaPool.on("error",()=>{});
+            this.handler = new Handler(this);
+        }
+        /*else if (databaseType == dbType.postgres) {
+            this.pgPool = new pg.Pool({ host, user, password, max: connectionLimit, database, idleTimeoutMillis: 30000, connectionTimeoutMillis: 2000 });
+            this.handler = new postgresHandler(this);
+        }*/
+        else throw new Error("Unsuported Database type!");
+
         this.name = database;
     }
-    async query(query: Query) {
-        //console.log(query);
-        return await this.pool.query(query);
+    async query(query: Query, printQuery = false) {
+        if (!this.connected) throw new Error("Not connected yet!");
+        if (printQuery) console.log(query);
+        if (this.type == dbType.mariadb) return await this.mariaPool.query(query);
+        /*else if (this.type == dbType.postgres) {
+            let res = await this.pgPool.query(query.sql, query.values);
+            console.log([...res.rows]);
+            return res.rows;
+        }*/
+        else throw new Error("Invalid Database Type!");
     }
     getHandler() {
+        if (!this.connected) throw new Error("Not connected yet!");
         return this.handler;
     }
 
     async sync(force = false) {
+        if (!this.connected) throw new Error("Not connected yet!");
         let handler = this.getHandler();
         await handler.syncDB(this, handler, force);
-        //this.tables.forEach(t=>{
-        //    console.log(handler.builders.query(handler.querys.create(handler,t)));
-        //})
     }
 
     newTable(name: string) {
@@ -42,17 +71,22 @@ export class DB {
         return null;
     }
     async close() {
-        if (this.pool) await this.pool.end();
+        if (!this.connected) throw new Error("Not connected yet!");
+        if (this.type == dbType.mariadb && this.mariaPool) await this.mariaPool.end();
+        //if (this.type == dbType.postgres && this.pgPool) await this.pgPool.end();
+        this.connected = false;
     }
 }
 
 export class Attribute {
     name: string;
+    nameO: string;
     table: Table;
     ops: attributeSettings;
     type: Datatype;
-    constructor(name: string, table: Table, type: Datatype, ops: attributeSettings) {
+    constructor(name: string, nameO: string, table: Table, type: Datatype, ops: attributeSettings) {
         this.name = name.toLowerCase();
+        this.nameO = nameO;
         this.type = type;
         this.table = table;
         this.ops = ops;
@@ -70,13 +104,13 @@ export class Attribute {
                 [this]
             ))
         }
-        if (ops.foreginKey != null) {
+        if (ops.foreignKey != null) {
             table.addConstraint(new foreignConstraint(
-                table.dbLangDatabaseInstance.name + "_" + table.dbLangTableName + "_" + name + "_foreign_constraint_to_" + ops.foreginKey.link.name,
+                table.dbLangDatabaseInstance.name + "_" + table.dbLangTableName + "_" + name + "_foreign_constraint_to_" + ops.foreignKey.link.name,
                 [this],
-                [ops.foreginKey.link],
-                ops.foreginKey.onDelete,
-                ops.foreginKey.onUpdate
+                [ops.foreignKey.link],
+                ops.foreignKey.onDelete,
+                ops.foreignKey.onUpdate
             ));
         }
     }
@@ -89,12 +123,15 @@ export class Attribute {
     serialize(handler: Handler) {
         return handler.builders.escapeID(this.name);
     }
-    toString(handler: Handler = this.table.dbLangDatabaseInstance.getHandler()) {
+    getString(handler: Handler = this.table.dbLangDatabaseInstance.getHandler()) {
         return this.table.serialize(handler) + "." + this.serialize(handler);
     }
     toStringFunc(handler: Handler) {
         return this.table.serialize(handler) + "(" + this.serialize(handler) + ")";
     }
+    toString() {
+        return this.table.dbLangTableName + "_" + this.name;
+    }
 }
 
 
@@ -117,9 +154,9 @@ export class Table {
     addAttribute(name: string, type: Datatype, ops: attributeSettings = {}, noErrorOnNameConflict = false) {
         let lowName = name.toLowerCase();
         if (this.dbLangTableAttributes[lowName] != null) throw new Error("You are tring to create an Attribute twise!");
-        let attr = new Attribute(lowName, this, type, ops);
+        let attr = new Attribute(lowName, name, this, type, ops);
         this.dbLangTableAttributes[lowName] = attr;
-        if (["serialize", "toString", "addAttribute", "dbLangTableName", "dbLangTableAttributes", "dbLangDatabaseInstance", "addConstraint", "addAttributes"].includes(lowName)) {
+        if (["serialize", "toString", "addAttribute", "dbLangTableName", "dbLangTableAttributes", "dbLangDatabaseInstance", "addConstraint", "addAttributes", "createAlias"].includes(lowName)) {
             if (!noErrorOnNameConflict) throw new Error("You cannot name Attribute like Methode of this Table!");
         } else {
             this[lowName] = attr;
@@ -133,10 +170,16 @@ export class Table {
         }));
     }
     addConstraint(c: Constraint) {
-        c.check(this);
+        let check = c.check(this);
+        if(typeof check == "string") throw new Error(check);
         this.dbLangConstrains.push(c);
     }
+    createAlias(name: string) {
+        return new TableAlias(name, this);
+    }
 }
 
-export * from './funcs';
-export { onAction };
+export * from './funcs.js';
+export { onAction, order };
+export { dbType as databaseType }
+export { readResponse, writeResponse, insertResponse, singleResponse }

src/dbStructure.ts

@@ -1,7 +1,8 @@
-import { Attribute, Table } from "./db";
-import { Handler } from "./defaultHandler";
-import { QueryBuilder } from "./query";
-import { allModifierInput, onAction, primaryData, serializeReturn } from "./types";
+import { Attribute, Table } from "./db.js";
+import { Handler } from "./defaultHandler.js";
+import { QueryBuilder } from "./query.js";
+import { sha256 } from "./tools.js";
+import { allModifierInput, joinElements, joinType, onAction, primaryData, serializeReturn } from "./types.js";
 
 export class Datatype {
     type: string;
@@ -42,16 +43,66 @@ export class Aggregation {
         return handler.aggregations[this.t as keyof typeof handler.aggregations](handler, this.a);
     }
 }
-export class Joins {
-
-    serialize(handler: Handler): QueryBuilder {
-        return new QueryBuilder();
+export interface Joins {
+    serialize(handler: Handler): QueryBuilder 
 }
+export class joinNatural implements Joins{
+    tables: joinElements[];
+    type: joinType;
+    constructor(tables:joinElements[], type: joinType){
+        this.tables = tables;
+        this.type = type;
+    }    
+    serialize(handler: Handler): QueryBuilder {
+        return handler.joins.natural(handler,this);
+    }
+    
+}
+export class onJoin implements Joins{
+    tableA: joinElements;
+    tableB: joinElements;
+    type: joinType;
+    on: BooleanModifier;
+    constructor(tableA: joinElements, tableB: joinElements, type: joinType, on: BooleanModifier){
+        this.tableA = tableA;
+        this.tableB = tableB;
+        this.type = type;
+        this.on = on;
+    }
+    serialize(handler: Handler): QueryBuilder {
+        return handler.joins.on(handler,this);
+    }
+    
+}
+export class usingJoin implements Joins{
+    tableA: joinElements;
+    tableB: joinElements;
+    type: joinType;
+    using: Attribute[];
+    constructor(tableA: joinElements, tableB: joinElements, type: joinType, using: Attribute[]){
+        this.tableA = tableA;
+        this.tableB = tableB;
+        this.type = type;
+        this.using = using;
+    }
+    serialize(handler: Handler): QueryBuilder {
+        return handler.joins.using(handler,this);
+    }
+    
+}
+export class joinCross implements Joins{
+    tables: joinElements[];
+    constructor(tables:joinElements[]){
+        this.tables = tables;
+    } 
+    serialize(handler: Handler): QueryBuilder {
+        return handler.joins.cross(handler,this);
+    }
+    
 }
 
 export interface Constraint {
     name: string;
-    serialize(handler: Handler): QueryBuilder;
     uses(attr: Attribute): boolean;
     check(table: Table): boolean | string;
 }
@@ -60,6 +111,7 @@ export class checkConstraint implements Constraint {
     checkQuery: BooleanModifier;
     name: string;
     constructor(name: string, check: BooleanModifier) {
+        if (name.length > 64) name = sha256(name);
         this.name = name.toLowerCase();
         this.checkQuery = check;
     }
@@ -69,32 +121,28 @@ export class checkConstraint implements Constraint {
     uses(attr: Attribute): boolean {
         throw new Error("Method not implemented.");
     }
-    serialize(handler: Handler): QueryBuilder {
-        throw new Error("Method not implemented.");
-    }
 }
 
 export class uniqueConstraint implements Constraint {
     name: string;
     attrs: Attribute[];
     constructor(name: string, attrs: Attribute[]) {
+        if (name.length > 64) name = sha256(name);
         this.name = name.toLowerCase();
         this.attrs = attrs;
     }
     check(table: Table): boolean | string {
+        let prim = true;
         for (let i = 0; i < this.attrs.length; i++) {
-            if (this.attrs[i].ops.primaryKey) return "Can not combine unique Constraint and primary key";
+            if (!this.attrs[i].ops.primaryKey) prim = false;
             if (this.attrs[i].table != table) return "Referencing Attributes must be in host Table.";
         }
+        if (prim) return "Can not combine unique Constraint and primary key";
         return false;
     }
     uses(attr: Attribute): boolean {
         return this.attrs.includes(attr);
     }
-    serialize(handler: Handler): QueryBuilder {
-        throw new Error("Method not implemented.");
-    }
-
 }
 
 export class foreignConstraint implements Constraint {
@@ -104,15 +152,13 @@ export class foreignConstraint implements Constraint {
     onUpdate: onAction;
     onDelete: onAction;
     constructor(name: string, from: Attribute[], to: Attribute[], onDelete: onAction = onAction.nothing, onUpdate: onAction = onAction.nothing) {
+        if (name.length > 64) name = sha256(name);
         this.name = name.toLowerCase();
         this.fromAttrs = from;
         this.toAttrs = to;
         this.onUpdate = onUpdate;
         this.onDelete = onDelete;
     }
-    serialize(handler: Handler): QueryBuilder {
-        throw new Error("Method not implemented.");
-    }
     uses(attr: Attribute): boolean {
         throw new Error("Method not implemented.");
     }
@@ -120,7 +166,7 @@ export class foreignConstraint implements Constraint {
         let table = this.toAttrs[0].table;
         for (let i = 0; i < this.toAttrs.length; i++) {
             if (table != this.toAttrs[i].table) return "Referenced Attributes must be in one Table.";
-            if (this.toAttrs[i].ops.primaryKey) return "Can not reference non primary keys.";
+            if (!this.toAttrs[i].ops.primaryKey) return "Can not reference non primary keys.";
         }
         for (let i = 0; i < this.fromAttrs.length; i++) {
             if (this.fromAttrs[i].table != t) return "Referencing Attributes must be in host Table.";

src/defaultHandler.ts

@@ -1,27 +1,22 @@
-import { Attribute, DB, Table } from "./db"
-import { Aggregation, checkConstraint, Constraint, Datatype, foreignConstraint, Modifier, uniqueConstraint } from "./dbStructure"
-import { insertQuery, Query, QueryBuilder, removeQuery, selectQuery, updateQuery } from "./query"
-import { allModifierInput, onAction, primaryData, serializeReturn } from "./types"
+import { Alias, AttributeAlias, TableAlias } from "./alias.js";
+import { Attribute, DB, insertResponse, readResponse, Table, writeResponse } from "./db.js"
+import { Aggregation, checkConstraint, joinCross, Datatype, foreignConstraint, Modifier, joinNatural, onJoin, uniqueConstraint, usingJoin } from "./dbStructure.js"
+import { insertQuery, Query, QueryBuilder, removeQuery, selectQuery, updateQuery } from "./query.js"
+import { allModifierInput, joinType, onAction, order, primaryData } from "./types.js"
+import { sha256 } from "./tools.js"
 
 export class Handler {
+    db: DB;
+    constructor(db: DB) {
+        this.db = db;
+    }
     async syncDB(db: DB, handler: Handler, deleteInDB: boolean = false) {
-        console.log("start sync");
-
-        let gd = new QueryBuilder();
-        gd.addCode(`SELECT * FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE where CONSTRAINT_SCHEMA = `);
-        gd.addInjection(db.name);
-        gd.addCode(` or TABLE_SCHEMA = `);
-        gd.addInjection(db.name);
-        gd.addCode(`;select * from information_schema.table_constraints where CONSTRAINT_SCHEMA = `);
-        gd.addInjection(db.name)
-        gd.addCode(` or TABLE_SCHEMA = `);
-        gd.addInjection(db.name);
-
-        let [key, constraints] = await db.query(handler.builders.query(gd));
+        //Constraint Data
+        let constraints = await db.query(handler.builders.query(handler.querys.listConstraints(handler, db)));
+        let key = [...await db.query(handler.builders.query(handler.querys.listConstraintDetails(handler, db)))];
 
         //Table List
-        let allTables = (await db.query(handler.builders.query(handler.querys.listTables(handler, db)))).map((d: any) => d.TABLE_NAME);
-
+        let allTables = (await db.query(handler.builders.query(handler.querys.listTables(handler, db)))).map((d: any) => d.TABLE_NAME ?? d.table_name);
         // gether Table Schematics
         let tableData: { [key: string]: any; } = {};
         for (let i = 0; i < db.tables.length; i++) {
@@ -30,15 +25,16 @@ export class Handler {
                 const tableDataBuilder = new QueryBuilder();
                 tableDataBuilder.addCode("DESCRIBE ");
                 tableDataBuilder.addCode(table.serialize(handler));
-                tableData[table.dbLangTableName.toLowerCase()] =
+                tableData[table.dbLangTableName] =
                     Object.fromEntries((await db.query(handler.builders.query(tableDataBuilder))).map((d: any) => [d.Field.toLowerCase(), d]));
             } catch (_) {
-                tableData[table.dbLangTableName.toLowerCase()] = null;
+                tableData[table.dbLangTableName] = null;
             }
         }
 
         const del = new QueryBuilder();
         const create = new QueryBuilder();
+        const connst = new QueryBuilder();
 
         function checkUniqueIsVaild(n: string, table: string) {
             let t = db.getTable(table);
@@ -50,10 +46,10 @@ export class Handler {
                     let found = 0;
                     for (let j = 0; j < key.length; j++) {
                         if (
-                            key[j].CONSTRAINT_NAME == n
-                            && key[j].TABLE_NAME == table
+                            (key[j].CONSTRAINT_NAME ?? key[j].constraint_name) == n
+                            && (key[j].TABLE_NAME ?? key[j].table_name) == table
                         ) {
-                            if (attrs.includes(key[j].COLUMN_NAME.toLowerCase())) found++;
+                            if (attrs.includes((key[j].COLUMN_NAME ?? key[j].column_name).toLowerCase())) found++;
                             else return false;
                         }
                     }
@@ -75,12 +71,12 @@ export class Handler {
                     let found = 0;
                     for (let j = 0; j < key.length; j++) {
                         if (
-                            key[j].CONSTRAINT_NAME == n
-                            && key[j].TABLE_NAME == table
-                            && key[j].REFERENCED_TABLE_NAME == refTable
+                            (key[j].CONSTRAINT_NAME ?? key[j].constraint_name) == n
+                            && (key[j].TABLE_NAME ?? key[j].table_name) == table
+                            && (key[j].REFERENCED_TABLE_NAME ?? key[j].referenced_table_name) == refTable
                         ) {
-                            let inF = fromAttrs.indexOf(key[j].COLUMN_NAME.toLowerCase());
-                            let inT = toAttrs.indexOf(key[j].REFERENCED_COLUMN_NAME.toLowerCase());
+                            let inF = fromAttrs.indexOf((key[j].COLUMN_NAME ?? key[j].column_name).toLowerCase());
+                            let inT = toAttrs.indexOf((key[j].REFERENCED_COLUMN_NAME ?? key[j].referenced_column_name).toLowerCase());
                             if (inF != -1 && inT == inF) found++;
                             else return false;
                         }
@@ -96,10 +92,10 @@ export class Handler {
             let found = 0;
             for (let j = 0; j < key.length; j++) {
                 if (
-                    key[j].CONSTRAINT_NAME.toLowerCase() == c.name
-                    && key[j].TABLE_NAME == tabel.dbLangTableName
+                    (key[j].CONSTRAINT_NAME ?? key[j].constraint_name).toLowerCase() == c.name
+                    && (key[j].TABLE_NAME ?? key[j].table_name) == tabel.dbLangTableName
                 ) {
-                    if (attrs.includes(key[j].COLUMN_NAME.toLowerCase())) found++;
+                    if (attrs.includes((key[j].COLUMN_NAME ?? key[j].column_name).toLowerCase())) found++;
                     else return false;
                 }
             }
@@ -112,12 +108,12 @@ export class Handler {
             let found = 0;
             for (let j = 0; j < key.length; j++) {
                 if (
-                    key[j].CONSTRAINT_NAME == c.name
-                    && key[j].TABLE_NAME == tabel.dbLangTableName
-                    && key[j].REFERENCED_TABLE_NAME == refTable
+                    (key[j].CONSTRAINT_NAME ?? key[j].constraint_name) == c.name
+                    && (key[j].TABLE_NAME ?? key[j].table_name) == tabel.dbLangTableName
+                    && (key[j].REFERENCED_TABLE_NAME ?? key[j].referenced_table_name) == refTable
                 ) {
-                    let inF = fromAttrs.indexOf(key[j].COLUMN_NAME.toLowerCase());
-                    let inT = toAttrs.indexOf(key[j].REFERENCED_COLUMN_NAME.toLowerCase());
+                    let inF = fromAttrs.indexOf((key[j].COLUMN_NAME ?? key[j].column_name).toLowerCase());
+                    let inT = toAttrs.indexOf((key[j].REFERENCED_COLUMN_NAME ?? key[j].referenced_column_name).toLowerCase());
                     if (inF != -1 && inT == inF) found++;
                     else return false;
                 }
@@ -125,44 +121,59 @@ export class Handler {
             return found == fromAttrs.length && found == toAttrs.length;
         }
 
+        function freeForUpdate(attr: string, table: string, start = false, pool = del) {
+            for (let i = 0; i < key.length; i++) {
+                const k = key[i];
+                if (
+                    ((k.REFERENCED_TABLE_NAME ?? k.referenced_table_name) == table
+                        && (k.REFERENCED_COLUMN_NAME ?? k.referenced_column_name).toLowerCase() == attr.toLowerCase())
+                    || (start && (k.TABLE_NAME ?? k.table_name) == table
+                        && (k.COLUMN_NAME ?? k.column_name).toLowerCase() == attr.toLowerCase() && (k.REFERENCED_COLUMN_NAME ?? k.referenced_column_name) != null)
+                ) {
+                    pool.appendEnding(handler.querys.removeForeignKey(handler, (k.TABLE_NAME ?? k.table_name), (k.CONSTRAINT_NAME ?? k.constraint_name)));
+                    key.splice(i--, 1);
+                }
+            }
+        }
+
         //delete check and unused/false(unique, foreign) constraints
         for (let i = 0; i < constraints.length; i++) {
             const c = constraints[i];
-            if (c.CONSTRAINT_TYPE == "CHECK") {
-                del.appendEnding(handler.querys.removeCheck(handler, c.TABLE_NAME, c.CONSTRAINT_NAME));
-            } else if (c.CONSTRAINT_TYPE == "UNIQUE") {
+            if ((c.CONSTRAINT_TYPE ?? c.constraint_type) == "CHECK") {
+                del.appendEnding(handler.querys.removeCheck(handler, (c.TABLE_NAME ?? c.table_name), (c.CONSTRAINT_NAME ?? c.constraint_name)));
+            } else if ((c.CONSTRAINT_TYPE ?? c.constraint_type) == "UNIQUE") {
                 if (
-                    (typeof tableData[c.TABLE_NAME.toLowerCase()] == "undefined" && deleteInDB)
-                    || !checkUniqueIsVaild(c.CONSTRAINT_NAME, c.TABLE_NAME)
-                ) del.appendEnding(handler.querys.removeUnique(handler, c.TABLE_NAME, c.CONSTRAINT_NAME));
-            } else if (c.CONSTRAINT_TYPE == "FOREIGN KEY") {
+                    (typeof tableData[c.TABLE_NAME ?? c.table_name] == "undefined" && deleteInDB)
+                    || !checkUniqueIsVaild((c.CONSTRAINT_NAME ?? c.constraint_name), (c.TABLE_NAME ?? c.table_name))
+                ) {
+                    const uTName = (c.TABLE_NAME ?? c.table_name);
+                    const uCName = (c.CONSTRAINT_NAME ?? c.constraint_name);
+                    for (let j = 0; j < key.length; j++) {
                         if (
-                    (typeof tableData[c.TABLE_NAME.toLowerCase()] == "undefined" && deleteInDB)
-                    || !checkForeignIsVaild(c.CONSTRAINT_NAME, c.TABLE_NAME)
-                ) del.appendEnding(handler.querys.removeForeignKey(handler, c.TABLE_NAME, c.CONSTRAINT_NAME));
+                            (key[j].CONSTRAINT_NAME ?? key[j].constraint_name) == uCName
+                            && (key[j].TABLE_NAME ?? key[j].table_name) == uTName
+                        ) {
+                            freeForUpdate((key[j].COLUMN_NAME ?? key[j].column_name), uTName, true);
+                        }
+                    }
+                    del.appendEnding(handler.querys.removeUnique(handler, uTName, uCName));
+                }
+            } else if ((c.CONSTRAINT_TYPE ?? c.constraint_type) == "FOREIGN KEY") {
+                if (
+                    (typeof tableData[c.TABLE_NAME ?? c.table_name] == "undefined" && deleteInDB)
+                    || !checkForeignIsVaild((c.CONSTRAINT_NAME ?? c.constraint_name), (c.TABLE_NAME ?? c.table_name))
+                ) del.appendEnding(handler.querys.removeForeignKey(handler, (c.TABLE_NAME ?? c.table_name), (c.CONSTRAINT_NAME ?? c.constraint_name)));
             }
         }
         //delete unused Tables
         if (deleteInDB) for (let i = 0; i < allTables.length; i++) {
-            if (typeof tableData[allTables[i].toLowerCase()] == "undefined") del.appendEnding(handler.querys.deleteTable(handler, allTables[i]));
-        }
-
-        function freeForUpdate(attr: string, table: string) {
-            for (let i = 0; i < key.length; i++) {
-                const k = key[i];
-                if (
-                    k.REFERENCED_TABLE_NAME == table
-                    && k.REFERENCED_COLUMN_NAME.toLowerCase() == attr.toLowerCase()
-                ) {
-                    del.appendEnding(handler.querys.removeForeignKey(handler, k.TABLE_NAME, k.CONSTRAINT_NAME));
-                }
-            }
+            if (typeof tableData[allTables[i]] == "undefined") del.appendEnding(handler.querys.deleteTable(handler, allTables[i]));
         }
 
         //create tables
         for (let i = 0; i < db.tables.length; i++) {
             const table = db.tables[i];
-            const tableD = tableData[table.dbLangTableName.toLowerCase()];
+            const tableD = tableData[table.dbLangTableName];
             //delete unused Columns
             if (deleteInDB && tableD != null) {
                 let keys = Object.keys(tableD);
@@ -177,58 +188,78 @@ export class Handler {
             let changePrimary = false;
             if (tableD == null) {
                 create.appendEnding(handler.querys.create(handler, table));
-                changePrimary = true;
+                //changePrimary = true;
             } else {
                 let keys = Object.keys(table.dbLangTableAttributes);
                 for (let j = 0; j < keys.length; j++) {
                     const a = table.dbLangTableAttributes[keys[j]];
                     const attrData = tableD[keys[j]];
                     if (attrData == null) {
+                        if (a.ops.autoIncrement) {
+                            a.ops.autoIncrement = false;
                             create.appendEnding(handler.querys.addColumn(handler, a));
-                        changePrimary = true;
+                            a.ops.autoIncrement = true;
+                            connst.appendEnding(handler.querys.addColumn(handler, a));
+                        }
+                        else create.appendEnding(handler.querys.addColumn(handler, a));
+                        if (a.ops.primaryKey) changePrimary = true;
                     } else if (
                         !handler.builders.compareDatatypes(handler, a.type, attrData.Type) ||
                         a.ops.default != attrData.Default ||
                         (!!a.ops.notNull || !!a.ops.autoIncrement || !!a.ops.primaryKey) != (attrData.Null == "NO") ||
                         (!!a.ops.autoIncrement) != (attrData.Extra == "auto_increment")
                     ) {
-                        /*console.log(!handler.builders.compareDatatypes(handler, a.type, attrData.Type), "|",
-                            a.ops.default, attrData.Default, "|",
-                            (!!a.ops.notNull || !!a.ops.autoIncrement || !!a.ops.primaryKey), (attrData.Null == "NO"), "|",
-                            (!!a.ops.autoIncrement), (attrData.Extra == "auto_increment"));*/
                         freeForUpdate(a.name, a.table.dbLangTableName);
+                        if (a.ops.autoIncrement) {
+                            a.ops.autoIncrement = false;
                             create.appendEnding(handler.querys.changeColumn(handler, a));
+                            a.ops.autoIncrement = true;
+                            connst.appendEnding(handler.querys.changeColumn(handler, a));
                         }
-                    if (attrData == null) {
-                        changePrimary = true;
-                    } else {
+                        else create.appendEnding(handler.querys.changeColumn(handler, a));
+                    }
+                    if (attrData != null) {
                         if ((attrData.Key == "PRI") != (!!a.ops.primaryKey)) {
                             freeForUpdate(a.name, a.table.dbLangTableName);
                             changePrimary = true;
                         }
                     }
                 }
+                if (changePrimary) for (let j = 0; j < keys.length; j++) {
+                    const a = table.dbLangTableAttributes[keys[j]];
+                    if (a.ops.autoIncrement) {
+                        a.ops.autoIncrement = false;
+                        create.appendEnding(handler.querys.changeColumn(handler, a));
+                        a.ops.autoIncrement = true;
+                        connst.appendEnding(handler.querys.changeColumn(handler, a));
+                    }
+                    freeForUpdate(a.name, a.table.dbLangTableName, true, create);
+                }
             }
             if (changePrimary) {
                 create.appendEnding(handler.querys.removePrimaryKey(handler, table.dbLangTableName));
                 create.appendEnding(handler.querys.addPrimaryKey(handler, table));
             }
+        }
+        for (let i = 0; i < db.tables.length; i++) {
+            const table = db.tables[i];
             for (let j = 0; j < table.dbLangConstrains.length; j++) {
                 const c = table.dbLangConstrains[j];
                 if (c instanceof checkConstraint) {
-                    create.appendEnding(handler.querys.addCheck(handler, table, c));
+                    connst.appendEnding(handler.querys.addCheck(handler, table, c));
                 } else if (c instanceof uniqueConstraint) {
                     if (!checkUniqueExists(table, c)) {
-                        create.appendEnding(handler.querys.addUnique(handler, table, c));
+                        connst.appendEnding(handler.querys.addUnique(handler, table, c));
                     }
                 } else if (c instanceof foreignConstraint) {
                     if (!checkForeignExists(table, c)) {
-                        create.appendEnding(handler.querys.addForeignKey(handler, table, c));
+                        connst.appendEnding(handler.querys.addForeignKey(handler, table, c));
                     }
                 }
             }
         }
         if (!create.isEmpty()) del.append(create);
+        if (!connst.isEmpty()) del.append(connst);
         if (!del.isEmpty()) await db.query(handler.builders.query(del));
     }
 
@@ -236,8 +267,34 @@ export class Handler {
         select: (handler: Handler, q: selectQuery): QueryBuilder => {
             const builder = new QueryBuilder();
             builder.addCode("select ");
-            builder.append(joinArg(", ")(handler, q.attr));
-            builder.addCode(` from ${q.from == null ? 'DUAL' : q.from.serialize(handler)}`);
+            let a = q.attr;
+            for (let i = 0; i < a.length; i++) {
+                const d = a[i];
+                if (d instanceof Attribute || d instanceof AttributeAlias)
+                    builder.addCode(d.getString(handler) + " " + handler.builders.escapeID(d.toString()));
+                else if (d instanceof Alias) {
+                    builder.append(d.serialize(handler));
+                    builder.addCode(handler.builders.escapeID(d.toString()));
+                } else if (d instanceof Modifier || d instanceof selectQuery || d instanceof Aggregation) {
+                    builder.addCode("(");
+                    builder.append(d.serialize(handler));
+                    builder.addCode(")");
+                } else {
+                    builder.addInjection(d);
+                }
+                if (i + 1 < a.length) builder.addCode(", ");
+            }
+            //builder.append(joinArg(", ")(handler, q.attr));
+            builder.addCode(` from `);
+            if (q.from == null) {
+                builder.addCode(" DUAL");
+            } else if (q.from instanceof Table) {
+                builder.addCode(q.from.serialize(handler));
+            } else if (q.from instanceof TableAlias) {
+                builder.addCode(q.from.serializeAlias(handler));
+            } else {
+                builder.append(q.from.serialize(handler));
+            }
             if (q.whereD) {
                 builder.addCode(" where ");
                 builder.append(q.whereD.serialize(handler));
@@ -250,9 +307,35 @@ export class Handler {
                     builder.append(q.havingD.serialize(handler));
                 }
             }
-            if (q.havingD) {
+            if (q.orderByD.length > 0) {
+                builder.addCode(" order by ");
+                for (let i = 0; i < q.orderByD.length; i++) {
+                    const d = q.orderByD[i];
+                    if (d[0] instanceof Attribute || d[0] instanceof AttributeAlias) builder.addCode(d[0].getString(handler));
+                    else if (d[0] instanceof Alias)
+                        builder.addCode(handler.builders.escapeID(d.toString()));
+                    else if (d[0] instanceof Modifier || d[0] instanceof selectQuery || d[0] instanceof Aggregation) {
+                        builder.addCode("(");
+                        builder.append(d[0].serialize(handler));
+                        builder.addCode(")");
+                    } else {
+                        builder.addInjection(d[0]);
+                    }
+                    if(d[1] == order.DESC) builder.addCode(" DESC");
+                    else builder.addCode(" ASC");
+                    if (i + 1 < q.orderByD.length) builder.addCode(", ");
+                }
+            }
+            if (q.limitD != null) {
+                if (q.limitOffsetD == null) {
                     builder.addCode(" limit ");
                     builder.addInjection(q.limitD);
+                } else {
+                    builder.addCode(" limit ");
+                    builder.addInjection(q.limitOffsetD);
+                    builder.addCode(", ");
+                    builder.addInjection(q.limitD);
+                }
             }
 
             /*builder.setHandler((json)=>{
@@ -263,7 +346,7 @@ export class Handler {
         },
         insert: (hander: Handler, q: insertQuery): QueryBuilder => {
             const qb = new QueryBuilder();
-            qb.addCode("INSERT INTO ");
+            qb.addCode("INSERT IGNORE INTO ");
             qb.addCode(q.attrs[0].table.serialize(hander));
             qb.addCode("(");
             qb.addCodeCommaSeperated(q.attrs.map(a => a.serialize(hander)));
@@ -290,7 +373,9 @@ export class Handler {
                 const s = q.setD[i];
                 qb.addCode(s[0].serialize(handler));
                 qb.addCode(" = (");
-                if (s[1] instanceof Attribute) qb.addCode(s[1].serialize(handler));
+                if (s[1] instanceof Attribute || s[1] instanceof AttributeAlias) qb.addCode(s[1].serialize(handler));
+                else if (s[1] instanceof Alias)
+                    qb.addCode(handler.builders.escapeID(s[1].toString()));
                 else if (s[1] instanceof Modifier || s[1] instanceof selectQuery || s[1] instanceof Aggregation) {
                     qb.append(s[1].serialize(handler));
                 } else {
@@ -319,7 +404,24 @@ export class Handler {
             const qb = new QueryBuilder();
             qb.addCode(`SELECT * FROM information_schema.tables where TABLE_SCHEMA = `);
             qb.addInjection(db.name);
-            qb.addCode(` and TABLE_TYPE  = "BASE TABLE"`);
+            qb.addCode(` and TABLE_TYPE  = `);
+            qb.addInjection("BASE TABLE");
+            return qb;
+        },
+        listConstraints: (handler: Handler, db: DB) => {
+            let qb = new QueryBuilder();
+            qb.addCode(`select * from information_schema.table_constraints where CONSTRAINT_SCHEMA = `);
+            qb.addInjection(db.name);
+            qb.addCode(` or TABLE_SCHEMA = `);
+            qb.addInjection(db.name);
+            return qb;
+        },
+        listConstraintDetails: (handler: Handler, db: DB) => {
+            let qb = new QueryBuilder();
+            qb.addCode(`SELECT * FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE where CONSTRAINT_SCHEMA = `);
+            qb.addInjection(db.name);
+            qb.addCode(` or TABLE_SCHEMA = `);
+            qb.addInjection(db.name);
             return qb;
         },
         create: (handler: Handler, table: Table): QueryBuilder => {
@@ -332,6 +434,15 @@ export class Handler {
                 builder.append(a.serializeSettings(handler));
                 if (i + 1 < keys.length) builder.addCode(", ");
             }
+            let primAttr = Object.entries(table.dbLangTableAttributes)
+                .filter(([n, attr]) => !!attr.ops.primaryKey);
+            if (primAttr.length > 0) {
+                builder.addCode(", primary key (");
+                builder.addCodeCommaSeperated(
+                    primAttr.map(([n, attr]) => handler.builders.escapeID(n))
+                );
+                builder.addCode(")");
+            }
             builder.addCode(")");
             return builder;
         },
@@ -408,14 +519,15 @@ export class Handler {
             return builder;
         },
         addPrimaryKey: (handler: Handler, table: Table) => {
+            let primaAttr = Object.entries(table.dbLangTableAttributes)
+                .filter(([n, attr]) => !!attr.ops.primaryKey);
             const qb = new QueryBuilder();
+            if (primaAttr.length == 0) return qb;
             qb.addCode("ALTER TABLE ");
             qb.addCode(table.serialize(handler));
             qb.addCode(" add PRIMARY KEY if not exists (");
             qb.addCodeCommaSeperated(
-                Object.entries(table.dbLangTableAttributes)
-                    .filter(([n, attr]) => !!attr.ops.primaryKey)
-                    .map(([n, attr]) => handler.builders.escapeID(n))
+                primaAttr.map(([n, attr]) => handler.builders.escapeID(n))
             );
             qb.addCode(")");
             return qb;
@@ -504,27 +616,128 @@ export class Handler {
         },
         escapeID: (key: string): string => {
             if (!key || key === "" || key.includes('\u0000')) throw new Error("Can not escape empty key or with null unicode!");
+            if (key.length > 64) key = sha256(key);
             if (key.match(/^`.+`$/g)) return key;
             return `\`${key.replace(/`/g, '``')}\``;
         },
+        escapeLiteral: (data: any): string => {
+            return this.db.mariaPool.escape(data);
+        },
         compareDatatypes: (handler: Handler, attr: Datatype, curr: String) => {
             let qb = attr.serialize(handler);
             let sql = "";
             for (let i = 0; i < qb.list.length; i++) {
                 const [inject, data] = qb.list[i];
-                sql += data;
+                if (inject) sql += handler.builders.escapeLiteral(data);
+                else sql += data;
             }
-
-            return curr.split(" ").join("").startsWith(sql.split(" ").join(""));
+            return curr.split(", ").join(",").startsWith(sql.split(", ").join(","));
         },
     }
 
+    responses = {
+        readResponse: (resp: any) => new readResponse(resp),
+        writeResponse: (resp: any) => new writeResponse(resp.affectedRows),
+        insertResponse: (resp: any) => new insertResponse(resp.affectedRows, resp.insertId),
+    }
+
     aggregations = {
-        count: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "count(" + a.toString(handler) + ")" }]),
-        sum: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "sum(" + a.toString(handler) + ")" }]),
-        avg: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "avg(" + a.toString(handler) + ")" }]),
-        min: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "min(" + a.toString(handler) + ")" }]),
-        max: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "max(" + a.toString(handler) + ")" }]),
+        count: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "count(" + a.getString(handler) + ")" }]),
+        sum: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "sum(" + a.getString(handler) + ")" }]),
+        avg: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "avg(" + a.getString(handler) + ")" }]),
+        min: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "min(" + a.getString(handler) + ")" }]),
+        max: (handler: Handler, a: Attribute): QueryBuilder => new QueryBuilder([{ data: "max(" + a.getString(handler) + ")" }]),
+    }
+
+    joins = {
+        natural: (handler: Handler, j: joinNatural) => {
+            const qb = new QueryBuilder();
+            for (let i = 0; i < j.tables.length; i++) {
+                const t = j.tables[i];
+                if (t instanceof Table) qb.addCode(t.serialize(handler));
+                else if (t instanceof TableAlias) qb.addCode(t.serializeAlias(handler));
+                else {
+                    qb.addCode("(");
+                    qb.append(t.serialize(handler));
+                    qb.addCode(")");
+                }
+                if (i + 1 < j.tables.length) {
+                    qb.addCode(" natural ");
+                    if (j.type == joinType.left) qb.addCode("left");
+                    if (j.type == joinType.right) qb.addCode("right");
+                    if (j.type == joinType.full) qb.addCode("full");
+                    qb.addCode(" join ");
+                }
+            }
+            return qb;
+        },
+        using: (handler: Handler, j: usingJoin) => {
+            const qb = new QueryBuilder();
+            if (j.tableA instanceof Table) qb.addCode(j.tableA.serialize(handler));
+            else if (j.tableA instanceof TableAlias) qb.addCode(j.tableA.serializeAlias(handler));
+            else {
+                qb.addCode("(");
+                qb.append(j.tableA.serialize(handler));
+                qb.addCode(")");
+            }
+            qb.addCode(" ");
+            if (j.type == joinType.left) qb.addCode("left ");
+            if (j.type == joinType.right) qb.addCode("right ");
+            if (j.type == joinType.full) qb.addCode("full ");
+            qb.addCode("join ");
+            if (j.tableB instanceof Table) qb.addCode(j.tableB.serialize(handler));
+            else if (j.tableB instanceof TableAlias) qb.addCode(j.tableB.serializeAlias(handler));
+            else {
+                qb.addCode("(");
+                qb.append(j.tableB.serialize(handler));
+                qb.addCode(")");
+            }
+            qb.addCode(" using (");
+            qb.addCodeCommaSeperated(j.using.map(t => t.serialize(handler)));
+            qb.addCode(")");
+            return qb;
+        },
+        on: (handler: Handler, j: onJoin) => {
+            const qb = new QueryBuilder();
+            if (j.tableA instanceof Table) qb.addCode(j.tableA.serialize(handler));
+            else if (j.tableA instanceof TableAlias) qb.addCode(j.tableA.serializeAlias(handler));
+            else {
+                qb.addCode("(");
+                qb.append(j.tableA.serialize(handler));
+                qb.addCode(")");
+            }
+            qb.addCode(" ");
+            if (j.type == joinType.left) qb.addCode("left ");
+            if (j.type == joinType.right) qb.addCode("right ");
+            if (j.type == joinType.full) qb.addCode("full ");
+            qb.addCode("join ");
+            if (j.tableB instanceof Table) qb.addCode(j.tableB.serialize(handler));
+            else if (j.tableB instanceof TableAlias) qb.addCode(j.tableB.serializeAlias(handler));
+            else {
+                qb.addCode("(");
+                qb.append(j.tableB.serialize(handler));
+                qb.addCode(")");
+            }
+            qb.addCode(" on (");
+            qb.append(j.on.serialize(handler));
+            qb.addCode(")");
+            return qb;
+        },
+        cross: (handler: Handler, j: joinCross) => {
+            const qb = new QueryBuilder();
+            for (let i = 0; i < j.tables.length; i++) {
+                const t = j.tables[i];
+                if (t instanceof Table) qb.addCode(t.serialize(handler));
+                else if (t instanceof TableAlias) qb.addCode(t.serializeAlias(handler));
+                else {
+                    qb.addCode("(");
+                    qb.append(t.serialize(handler));
+                    qb.addCode(")");
+                }
+                if (i + 1 < j.tables.length) qb.addCode(" cross join ");
+            }
+            return qb;
+        }
     }
 
     modifiers = {
@@ -541,7 +754,9 @@ export class Handler {
         divide: joinArg("-/"),
         not: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
             let e = a[0];
-            if (e instanceof Attribute) return new QueryBuilder([{ data: "not (" + e.toString(handler) + ")" }])
+            if (e instanceof Attribute || e instanceof AttributeAlias) return new QueryBuilder([{ data: "not (" + e.getString(handler) + ")" }])
+            if (e instanceof Alias)
+                return new QueryBuilder([{ data: handler.builders.escapeID(e.toString()) }]);
             if (e instanceof Modifier || e instanceof selectQuery || e instanceof Aggregation) {
                 const builder = new QueryBuilder();
                 builder.addCode("not (");
@@ -557,14 +772,18 @@ export class Handler {
         },
         like: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
             const builder = new QueryBuilder();
-            if (a[0] instanceof Attribute) builder.addCode(a[0].toString());
+            if (a[0] instanceof Attribute || a[0] instanceof AttributeAlias) builder.addCode(a[0].getString());
+            else if (a[0] instanceof Alias)
+                builder.addCode(handler.builders.escapeID(a[0].toString()));
             else if (a[0] instanceof Modifier || a[0] instanceof selectQuery || a[0] instanceof Aggregation) {
                 builder.append(a[0].serialize(handler));
             } else {
                 builder.addInjection(a[0]);
             }
             builder.addCode(" LIKE ");
-            if (a[1] instanceof Attribute) builder.addCode(a[1].toString());
+            if (a[1] instanceof Attribute || a[1] instanceof AttributeAlias) builder.addCode(a[1].getString());
+            else if (a[1] instanceof Alias)
+                builder.addCode(handler.builders.escapeID(a[1].toString()));
             else if (a[1] instanceof Modifier || a[1] instanceof selectQuery || a[1] instanceof Aggregation) {
                 builder.append(a[1].serialize(handler));
             } else {
@@ -572,12 +791,53 @@ export class Handler {
             }
             return builder;
         },
+        regexp: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
+            const builder = new QueryBuilder();
+            if (a[0] instanceof Attribute || a[0] instanceof AttributeAlias) builder.addCode(a[0].getString());
+            else if (a[0] instanceof Alias)
+                builder.addCode(handler.builders.escapeID(a[0].toString()));
+            else if (a[0] instanceof Modifier || a[0] instanceof selectQuery || a[0] instanceof Aggregation) {
+                builder.append(a[0].serialize(handler));
+            } else {
+                builder.addInjection(a[0]);
+            }
+            builder.addCode(" REGEXP ");
+            if (a[1] instanceof Attribute || a[1] instanceof AttributeAlias) builder.addCode(a[1].getString());
+            else if (a[1] instanceof Alias)
+                builder.addCode(handler.builders.escapeID(a[1].toString()));
+            else if (a[1] instanceof Modifier || a[1] instanceof selectQuery || a[1] instanceof Aggregation) {
+                builder.append(a[1].serialize(handler));
+            } else {
+                builder.addInjection(a[1]);
+            }
+            return builder;
+        },
+        exists: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
+            let e = a[0];
+            if (e instanceof Attribute || e instanceof AttributeAlias) return new QueryBuilder([{ data: "exists (" + e.getString(handler) + ")" }])
+            if (e instanceof Alias)
+                return new QueryBuilder([{ data: handler.builders.escapeID(e.toString()) }]);
+            if (e instanceof Modifier || e instanceof selectQuery || e instanceof Aggregation) {
+                const builder = new QueryBuilder();
+                builder.addCode("exists (");
+                builder.append(e.serialize(handler));
+                builder.addCode(")");
+                return builder;
+            }
+            return new QueryBuilder([
+                { data: "exists (" },
+                { inject: true, data: e },
+                { data: ")" }
+            ]);
+        },
         concat: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
             const builder = new QueryBuilder();
             builder.addCode("CONCAT(");
             for (let i = 0; i < a.length; i++) {
                 const e = a[i];
-                if (e instanceof Attribute) builder.addCode(e.toString());
+                if (e instanceof Attribute || e instanceof AttributeAlias) builder.addCode(e.getString());
+                else if (e instanceof Alias)
+                    builder.addCode(handler.builders.escapeID(e.toString()));
                 else if (e instanceof Modifier || e instanceof selectQuery || e instanceof Aggregation) {
                     builder.append(e.serialize(handler));
                 } else {
@@ -587,7 +847,25 @@ export class Handler {
             }
             builder.addCode(")");
             return builder;
+        },
+        coalesce: (handler: Handler, a: allModifierInput[]): QueryBuilder => {
+            const builder = new QueryBuilder();
+            builder.addCode("COALESCE(");
+            for (let i = 0; i < a.length; i++) {
+                const e = a[i];
+                if (e instanceof Attribute || e instanceof AttributeAlias) builder.addCode(e.getString());
+                else if (e instanceof Alias)
+                    builder.addCode(handler.builders.escapeID(e.toString()));
+                else if (e instanceof Modifier || e instanceof selectQuery || e instanceof Aggregation) {
+                    builder.append(e.serialize(handler));
+                } else {
+                    builder.addInjection(e);
                 }
+                if (i < a.length - 1) builder.addCode(", ");
+            }
+            builder.addCode(")");
+            return builder;
+        },
     }
 
     datatypes = {
@@ -619,7 +897,7 @@ export class Handler {
             builder.addCode(")");
             return builder;
         },
-        bool: dataTypeNoArg("bool"),
+        bool: dataTypeNoArg("tinyint"),
         bit: dataTypeNoArg("bit"),
         tinyint: dataTypeNoArg("tinyint"),
         smallint: dataTypeNoArg("smallint"),
@@ -675,7 +953,9 @@ function joinArg(type: string) {
         const builder = new QueryBuilder();
         for (let i = 0; i < a.length; i++) {
             const d = a[i];
-            if (d instanceof Attribute) builder.addCode(d.toString(handler));
+            if (d instanceof Attribute || d instanceof AttributeAlias) builder.addCode(d.getString(handler));
+            else if (d instanceof Alias)
+                builder.addCode(handler.builders.escapeID(d.toString()));
             else if (d instanceof Modifier || d instanceof selectQuery || d instanceof Aggregation) {
                 builder.addCode("(");
                 builder.append(d.serialize(handler));

src/funcs.ts

@@ -1,7 +1,8 @@
-import { Attribute, Table } from "./db";
-import { Aggregation, BooleanModifier, checkConstraint, Datatype, foreignConstraint, NumberModifier, StringModifier, uniqueConstraint } from "./dbStructure";
-import { insertQuery, removeQuery, selectQuery, updateQuery } from "./query";
-import { allModifierInput, selectElements, selectFromElements } from "./types";
+import { Alias } from "./alias.js";
+import { Attribute, Table } from "./db.js";
+import { Aggregation, BooleanModifier, checkConstraint, Datatype, foreignConstraint, joinCross, joinNatural, usingJoin, onJoin, NumberModifier, StringModifier, uniqueConstraint } from "./dbStructure.js";
+import { insertQuery, removeQuery, selectQuery, updateQuery } from "./query.js";
+import { allModifierInput, joinType, selectElements, selectFromElements } from "./types.js";
 
 //modifiers
 export const and = (...args: BooleanModifier[]) => new BooleanModifier("and", args);
@@ -18,8 +19,12 @@ export const divide = (...args: allModifierInput[]) => new NumberModifier("divid
 
 export const not = (arg: allModifierInput) => new BooleanModifier("not", [arg]);
 export const like = (a: allModifierInput, b: allModifierInput) => new BooleanModifier("like", [a, b]);
+export const regexp = (a: allModifierInput, b: allModifierInput) => new BooleanModifier("regexp", [a, b]);
+
+export const exists = (q: selectQuery) => new BooleanModifier("exists", [q]);
 
 export const concat = (...args: allModifierInput[]) => new StringModifier("concat", args);
+export const coalesce = (...args: allModifierInput[]) => new StringModifier("coalesce", args);
 
 //aggregations
 export const count = (a: Attribute) => new Aggregation("count", a);
@@ -28,12 +33,34 @@ export const avg = (a: Attribute) => new Aggregation("avg", a);
 export const min = (a: Attribute) => new Aggregation("min", a);
 export const max = (a: Attribute) => new Aggregation("max", a);
 
+//join
+
+export const crossJoin = (...tables: Table[]) => new joinCross(tables);
+
+export const naturalJoin = (...tables: Table[]) => new joinNatural(tables, joinType.inner);
+export const leftNaturalJoin = (...tables: Table[]) => new joinNatural(tables, joinType.left);
+export const rightNaturalJoin = (...tables: Table[]) => new joinNatural(tables, joinType.right);
+export const fullNaturalJoin = (...tables: Table[]) => new joinNatural(tables, joinType.full);
+
+export const innerJoinUsing = (tableA: Table, tableB: Table, ...using: Attribute[]) => new usingJoin(tableA, tableB, joinType.inner, using);
+export const leftJoinUsing = (tableA: Table, tableB: Table, ...using: Attribute[]) => new usingJoin(tableA, tableB, joinType.left, using);
+export const rightJoinUsing = (tableA: Table, tableB: Table, ...using: Attribute[]) => new usingJoin(tableA, tableB, joinType.right, using);
+export const fullJoinUsing = (tableA: Table, tableB: Table, ...using: Attribute[]) => new usingJoin(tableA, tableB, joinType.full, using);
+
+export const innerJoinOn = (tableA: Table, tableB: Table, on: BooleanModifier) => new onJoin(tableA, tableB, joinType.inner, on);
+export const leftJoinOn = (tableA: Table, tableB: Table, on: BooleanModifier) => new onJoin(tableA, tableB, joinType.left, on);
+export const rightJoinOn = (tableA: Table, tableB: Table, on: BooleanModifier) => new onJoin(tableA, tableB, joinType.right, on);
+export const fullJoinOn = (tableA: Table, tableB: Table, on: BooleanModifier) => new onJoin(tableA, tableB, joinType.full, on);
+
 //query
 export const select = (args: selectElements[], from: selectFromElements) => new selectQuery(args, from);
 export const insert = (...attrs: Attribute[]) => new insertQuery(attrs);
 export const update = (table: Table) => new updateQuery(table);
 export const remove = (table: Table) => new removeQuery(table);
 
+//alias
+export const alias = (a: selectElements, name: string) => new Alias(a, name);
+
 //datatypes
 
 export const CHAR = (size: number) => new Datatype("char", [size]);

src/query.ts

@@ -1,7 +1,8 @@
-import { Attribute, DB, Table } from "./db";
-import { BooleanModifier, Modifier } from "./dbStructure";
-import { Handler } from "./defaultHandler";
-import { allModifierInput, primaryData, selectElements, selectFromElements, serializeReturn } from "./types";
+import { AttributeAlias } from "./alias.js";
+import { Attribute, DB, Table } from "./db.js";
+import { BooleanModifier, Modifier } from "./dbStructure.js";
+import { Handler } from "./defaultHandler.js";
+import { allModifierInput, order, primaryData, selectElements, selectFromElements, serializeReturn } from "./types.js";
 
 
 export class Query {
@@ -48,6 +49,7 @@ export class QueryBuilder {
         this.list.push(...qb.list);
     }
     appendEnding(qb: QueryBuilder) {
+        if (qb.isEmpty()) return;
         this.append(qb);
         this.list.push([false, ";"]);
     }
@@ -72,8 +74,8 @@ export class selectQuery {
         this.whereD = m;
         return this;
     }
-    groupByD: Attribute[] = [];
-    groupBy(a: Attribute[]) {
+    groupByD: (Attribute | AttributeAlias)[] = [];
+    groupBy(a: (Attribute | AttributeAlias)[]) {
         this.groupByD = a;
         return this;
     }
@@ -82,9 +84,22 @@ export class selectQuery {
         this.havingD = m;
         return this;
     }
+
+    orderByD: ([allModifierInput, order])[] = [];
+    addOrderBy(a: allModifierInput, o: order = order.ASC) {
+        this.orderByD.push([a, o]);
+        return this;
+    }
+    orderBY(a: allModifierInput, o: order = order.ASC) {
+        this.orderByD = [[a, o]];
+        return this;
+    }
+
     limitD: number | null = null;
-    limit(i: number) {
+    limitOffsetD: number | null = null;
+    limit(i: number, offset: number = 0) {
         this.limitD = i;
+        this.limitOffsetD = offset;
         return this;
     }
 
@@ -92,11 +107,12 @@ export class selectQuery {
         return handler.querys.select(handler, this);
     }
 
-    async query(db: DB) {
+    async query(db: DB, printQuery = false) {
         const handler = db.getHandler();
         const builder = this.serialize(handler);
         const s = handler.builders.query(builder);
-        return await db.query(s);
+        let readResp = await db.query(s, printQuery);
+        return handler.responses.readResponse(readResp);
     }
 }
 
@@ -129,11 +145,12 @@ export class insertQuery {
     serialize(handler: Handler): QueryBuilder {
         return handler.querys.insert(handler, this);
     }
-    async query(db: DB) {
+    async query(db: DB, printQuery = false) {
         const handler = db.getHandler();
         const builder = this.serialize(handler);
         const s = handler.builders.query(builder);
-        return await db.query(s);
+        let readResp = await db.query(s, printQuery);
+        return handler.responses.insertResponse(readResp);
     }
 }
 
@@ -157,11 +174,12 @@ export class updateQuery {
     serialize(handler: Handler): QueryBuilder {
         return handler.querys.update(handler, this);
     }
-    async query(db: DB) {
+    async query(db: DB, printQuery = false) {
         const handler = db.getHandler();
         const builder = this.serialize(handler);
         const s = handler.builders.query(builder);
-        return await db.query(s);
+        let readResp = await db.query(s, printQuery);
+        return handler.responses.writeResponse(readResp);
     }
 }
 
@@ -178,10 +196,11 @@ export class removeQuery {
     serialize(handler: Handler): QueryBuilder {
         return handler.querys.remove(handler, this);
     }
-    async query(db: DB) {
+    async query(db: DB, printQuery = false) {
         const handler = db.getHandler();
         const builder = this.serialize(handler);
         const s = handler.builders.query(builder);
-        return await db.query(s);
+        let readResp = await db.query(s, printQuery);
+        return handler.responses.writeResponse(readResp);
     }
 }

src/responses.ts

@@ -0,0 +1,37 @@
+import { AttributeAlias } from "./alias.js";
+import { Attribute } from "./db.js";
+import { primaryData } from "./types.js";
+
+export class singleResponse {
+    [key: string]: primaryData | any;
+    constructor(r: object) {
+        Object.assign(this, r);
+    }
+    getVal(a: Attribute | AttributeAlias) {
+        return this[a.toString()];
+    }
+}
+
+export class readResponse extends Array<singleResponse>{
+    constructor(rows: ({ [key: string]: primaryData })[]) {
+        super();
+        for(let i = 0; i < rows.length; i++){
+            this[i] = new singleResponse(rows[i])
+        }
+    }
+}
+
+export class writeResponse {
+    affectedRows: number;
+    constructor(affectedRows: number) {
+        this.affectedRows = affectedRows;
+    }
+}
+
+export class insertResponse extends writeResponse {
+    insertId: number;
+    constructor(affectedRows: number, insertId: number) {
+        super(affectedRows);
+        this.insertId = insertId;
+    }
+}

src/tools.ts

@@ -0,0 +1,3 @@
+import crypto from "crypto";
+
+export const sha256 = (d: any) => crypto.createHash('sha256').update(String(d)).digest('base64');

src/types.ts

@@ -1,12 +1,14 @@
-import { Attribute, Table } from "./db";
-import { Aggregation, BooleanModifier, Datatype, Joins, Modifier } from "./dbStructure";
-import { QueryBuilder, selectQuery } from "./query";
+import { Alias, AttributeAlias, TableAlias } from "./alias.js";
+import { Attribute, Table } from "./db.js";
+import { Aggregation, BooleanModifier, Datatype, Joins, Modifier } from "./dbStructure.js";
+import { QueryBuilder, selectQuery } from "./query.js";
 
 export type primaryData = string | number | boolean | null;
-export type allModifierInput = primaryData | Modifier | selectQuery | Attribute | Aggregation;
+export type allModifierInput = primaryData | Modifier | selectQuery | Attribute | AttributeAlias | Aggregation | Alias;
 
-export type selectElements = primaryData | Attribute | Aggregation | selectQuery
-export type selectFromElements = Table | Joins | null;
+export type selectElements = primaryData | Attribute | AttributeAlias | Aggregation | selectQuery | Alias;
+export type selectFromElements = TableAlias | Table | Joins | null;
+export type joinElements = Table | Joins;
 
 export type serializeReturn = [string, primaryData[]];
 
@@ -18,7 +20,7 @@ export type attributeSettings = {
     default?: primaryData,
     notNull?: boolean
     primaryKey?: boolean,
-    foreginKey?: {
+    foreignKey?: {
         link: Attribute,
         onDelete?: onAction,
         onUpdate?: onAction
@@ -33,7 +35,7 @@ export type extendedAttributeSettings = {
     default?: primaryData,
     notNull?: boolean
     primaryKey?: boolean,
-    foreginKey?: {
+    foreignKey?: {
         link: Attribute,
         onDelete?: onAction,
         onUpdate?: onAction
@@ -48,3 +50,22 @@ export enum onAction {
     setNull,
     setDefault
 }
+
+export enum joinType {
+    inner,
+    left,
+    right,
+    full,
+    cross
+}
+
+export enum dbType {
+    mariadb,
+    //mysql,
+    postgres,
+}
+
+export enum order {
+    ASC,
+    DESC
+}

tsconfig.json

@@ -1,6 +1,7 @@
 {
   "compilerOptions": {
-    "module": "CommonJS",
+    "target": "ES6",
+    "module": "ES6",
     "lib": ["es6"],
     "types": ["node"],
     "declaration": true,