dml-operation (#10)

* dml-operation

* fixed1:dml-operation

* fixed2:dml-operation

* fixed3:dml-operation

* fixbgt unused-var

* fixed code

Author: rifasania

.eslintrc.js

@@ -18,6 +18,7 @@ module.exports = {
     rules: {
       "prettier/prettier": "error",
       "@typescript-eslint/no-explicit-any": "warn",
+      "@typescript-eslint/no-unused-vars": "off"
     },
   };
 

eslint.config.mjs

@@ -20,6 +20,7 @@ export default [
       "@typescript-eslint/no-explicit-any": "off",
       "@typescript-eslint/no-var-requires": "off",
       "no-undef": "off",
+      "@typescript-eslint/no-unused-vars": "off",
     },
   },
   {
@@ -30,6 +31,7 @@ export default [
     rules: {
       "no-undef": "off",
       "@typescript-eslint/no-var-requires": "off",
+      "@typescript-eslint/no-unused-vars": "off",
     },
   },
 ];

package.json

@@ -21,6 +21,7 @@
     "jsonwebtoken": "8.5.1",
     "nanoid": "3",
     "pg": "^8.13.3",
+    "pg-format": "^1.0.4",
     "pg-hstore": "^2.3.4",
     "sequelize": "^6.37.5",
     "uuid": "^11.0.5"

src/config/database.ts

@@ -19,4 +19,5 @@ const sequelize = new Sequelize(
   },
 );
 
+import '../models/relations';
 export { sequelize };

src/controllers/ddl-controller.ts

@@ -1,11 +1,11 @@
 import { Request, Response } from 'express';
 import { sequelize } from '../config/database';
 import { successResponse, errorResponse } from '../utils/response';
-import { Operations } from '../types/ddl';
+import { DDLOperations } from '../types/ddl';
 import { DDLExecutor } from '../operations/migrate';
 
 export const migrate = async (req: Request, res: Response) => {
-  const { operations }: { operations: Operations[] } = req.body;
+  const { operations }: { operations: DDLOperations[] } = req.body;
   if (!operations || !Array.isArray(operations))
     return errorResponse(res, 'Invalid payload structure', 400);
 

src/controllers/dml-controller.ts

@@ -0,0 +1,26 @@
+import { Request, Response } from 'express';
+import { sequelize } from '../config/database';
+import { successResponse, errorResponse } from '../utils/response';
+import { DMLOperations } from '../types/dml';
+import { DMLExecutor } from '../operations/execute';
+
+export const execute = async (req: Request, res: Response) => {
+  const { operations }: { operations: DMLOperations[] } = req.body;
+  if (!operations || !Array.isArray(operations))
+    return errorResponse(res, 'Invalid payload structure', 400);
+
+  const transaction = await sequelize.transaction();
+
+  try {
+    const result = await DMLExecutor.execute(operations, transaction);
+    await transaction.commit();
+    return successResponse(
+      res,
+      result,
+      'DML operations completed successfully',
+    );
+  } catch (error: any) {
+    await transaction.rollback();
+    return errorResponse(res, error.message, 500);
+  }
+};

src/controllers/schema-controller.ts

@@ -0,0 +1,14 @@
+import { Request, Response } from 'express';
+import SchemaRepository from '../repositories/schema-repository';
+
+export const schema = async (req: Request, res: Response) => {
+  try {
+    const tables = await SchemaRepository.getSchemas();
+
+    return res.json({ success: true, tables });
+  } catch (error) {
+    const errorMessage =
+      error instanceof Error ? error.message : 'Unknown error';
+    res.status(500).json({ error: errorMessage });
+  }
+};

src/index.ts

@@ -4,9 +4,11 @@ import userRoutes from './routes/user-routes';
 import authRoutes from './routes/auth-routes';
 import ddlRoutes from './routes/ddl-routes';
 import { sequelize } from './config/database';
+import schemaRoutes from './routes/schema-routes';
+import dmlRoutes from './routes/dml-routes';
 
 sequelize
-  .sync({ force: true })
+  .sync({ alter: true })
   .then(async () => {
     console.log('Database synchronized successfully.');
   })
@@ -26,6 +28,8 @@ const apiRouter = express.Router();
 apiRouter.use('/auth', authRoutes);
 apiRouter.use('/users', userRoutes);
 apiRouter.use('/migrate', ddlRoutes);
+apiRouter.use('/schemas', schemaRoutes);
+apiRouter.use('/execute', dmlRoutes);
 
 app.use('/api', apiRouter);
 

src/models/metadata-column.ts

@@ -68,9 +68,4 @@ MetadataColumn.init(
   },
 );
 
-MetadataColumn.belongsTo(MetadataTable, {
-  foreignKey: 'table_id',
-  onDelete: 'CASCADE',
-});
-
 export default MetadataColumn;

src/models/metadata-table.ts

@@ -6,7 +6,6 @@ class MetadataTable extends Model {
   public table_name!: string;
   public readonly createdAt!: Date;
   public readonly updatedAt!: Date;
-  primaryKey: any;
 }
 
 MetadataTable.init(