How to Perform CRUD Operations Using API in Magento 2

One of the most commonly required operations in the Magento 2 store while managing a database is to perform CRUD operations. CRUD stands for Create, Read, Update and Delete.

Magento 2 offers the collection to manage data in a database easily. That’s why we don’t have to write many lines of code to create a CRUD.

However, what if we want to perform such kinds of operations based on API requests or integrate API on the frontend?

For instance, you need to send data from other platforms’ registration forms to the Magento database or integrate API in mobile. For such requirements, we have to call an API that sends a request to the server.

In such scenarios, use the below code to perform CRUD operation using API in Magento 2!

Steps to Perform CRUD Operations Using API in Magento 2

1. Create module.xml at app/code/Vendor/Module/etc/ and use the below code.
   
   <?xml version="1.0"?> <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd"> <module name="Vendor_Module" setup_version="1.0.0" /> </config>

   1 2 3 4

   <?xml version="1.0"?> <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">     <module name="Vendor_Module" setup_version="1.0.0" /> </config>

2. Create registration.php at app/code/Vendor/Module/ and paste the below code:
   
   <?php \Magento\Framework\Component\ComponentRegistrar::register( \Magento\Framework\Component\ComponentRegistrar::MODULE, 'Vendor_Module', __DIR__ );

   1 2 3 4 5 6

   <?php \Magento\Framework\Component\ComponentRegistrar::register(     \Magento\Framework\Component\ComponentRegistrar::MODULE,     'Vendor_Module',     __DIR__ );

3. Create webapi.xml at app/code/Vendor/Module/etc/ with the below code:
   
   <?xml version="1.0"?> <routes xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="../../../../../app/code/Magento/Webapi/etc/webapi.xsd"> <route method="POST" url="/V1/custom/custom-api/"> <service class="Vendor\Module\Api\CustomInterface" method="getPost"/> <resources> <resource ref="anonymous"/> </resources> </route> <route method="GET" url="/V1/custom/getdata/"> <service class="Vendor\Module\Api\CustomInterface" method="getData"/> <resources> <resource ref="anonymous"/> </resources> </route> <route method="GET" url="/V1/custom/delete/"> <service class="Vendor\Module\Api\CustomInterface" method="getDelete"/> <resources> <resource ref="anonymous"/> </resources> </route> <route method="GET" url="/V1/custom/getbyid/"> <service class="Vendor\Module\Api\CustomInterface" method="getById"/> <resources> <resource ref="anonymous"/> </resources> </route> <route method="POST" url="/V1/custom/edit/"> <service class="Vendor\Module\Api\CustomInterface" method="getEdit"/> <resources> <resource ref="anonymous"/> </resources> </route> </routes>

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34

   <?xml version="1.0"?> <routes xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:noNamespaceSchemaLocation="../../../../../app/code/Magento/Webapi/etc/webapi.xsd">     <route method="POST" url="/V1/custom/custom-api/">         <service class="Vendor\Module\Api\CustomInterface" method="getPost"/>         <resources>             <resource ref="anonymous"/>         </resources>     </route>     <route method="GET" url="/V1/custom/getdata/">         <service class="Vendor\Module\Api\CustomInterface" method="getData"/>         <resources>             <resource ref="anonymous"/>         </resources>     </route>     <route method="GET" url="/V1/custom/delete/">         <service class="Vendor\Module\Api\CustomInterface" method="getDelete"/>         <resources>             <resource ref="anonymous"/>         </resources>     </route>     <route method="GET" url="/V1/custom/getbyid/">         <service class="Vendor\Module\Api\CustomInterface" method="getById"/>         <resources>             <resource ref="anonymous"/>         </resources>     </route>     <route method="POST" url="/V1/custom/edit/">         <service class="Vendor\Module\Api\CustomInterface" method="getEdit"/>         <resources>             <resource ref="anonymous"/>         </resources>     </route> </routes>

4. Create di.xml at app/code/Vendor/Module/etc/ and use the below code:
   
   <?xml version="1.0"?> <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:ObjectManager/etc/config.xsd"> <preference for="Vendor\Module\Api\CustomInterface" type="Vendor\Module\Model\Api\Custom"/> </config>

   1 2 3 4

   <?xml version="1.0"?> <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:ObjectManager/etc/config.xsd">     <preference for="Vendor\Module\Api\CustomInterface" type="Vendor\Module\Model\Api\Custom"/> </config>

5. Create CustomInterface.php at app/code/Vendor/Module/Api/
   
   
   <?php namespace Vendor\Module\Api; interface CustomInterface { /** * GET for Post api * @param string $title * @return string */ public function getPost($title); /** * @return string */ public function getData(); /** * @param int $id * @return bool true on success */ public function getDelete($id); /** * @param int $id * @return string */ public function getById($id); /** * GET for Post api * @param string $title * @return string */ public function getEdit($title); }

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38

   <?php   namespace Vendor\Module\Api;     interface CustomInterface {     /**      * GET for Post api      * @param string $title      * @return string      */     public function getPost($title);       /**      * @return string      */     public function getData();       /**      * @param int $id      * @return bool true on success      */     public function getDelete($id);       /**      * @param int $id      * @return string      */     public function getById($id);       /**      * GET for Post api      * @param string $title      * @return string      */     public function getEdit($title); }

6. Create Custom.php at app/code/Vendor/Module/Model/Api/ and use the below code:
   
   <?php namespace Vendor\Module\Model\Api; use Vendor\Module\Api\CustomInterface; use Vendor\Module\Model\ModuleFactory; class Custom implements CustomInterface { private $moduleFactory; private $quote; protected $response = ['success' => false]; public function __construct(moduleFactory $moduleFactory, \Magento\Quote\Model\Quote $quote) { $this->quote = $quote; $this->moduleFactory = $moduleFactory; } /** * GET for Post api * @param string $title * @return string */ public function getPost($title) { $insertData = $this->moduleFactory->create(); try { $insertData->setTitle($data['title'])->save(); $response = ['success' => true, 'message' => $data]; } catch (\Exception $e) { $response = ['success' => false, 'message' => $e->getMessage()]; } return $response; } /** * @return string */ public function getData() { try { $data = $this->moduleFactory->create()->getCollection()->getData(); return $data; } catch (\Exception $e) { return ['success' => false, 'message' => $e->getMessage()]; } } /** * @param int $id * @return bool true on success */ public function getDelete($id) { try { if ($id) { $data = $this->moduleFactory->create()->load($id); $data->delete(); return "success"; } } catch (\Exception $e) { $response = ['success' => false, 'message' => $e->getMessage()]; } return "false"; } /** * @param int $id * @return string */ public function getById($id) { try { if ($id) { $data = $this->moduleFactory->create()->load($id)->getData(); return ['success' => true, 'message' => json_encode($data)]; } } catch (\Exception $e) { return ['success' => false, 'message' => $e->getMessage()]; } } /** * GET for Post api * @param string $title * @return string */ public function getEdit($title) { $edit = file_get_contents("php://input"); $data = json_decode($edit, true); $insertData = $this->moduleFactory->create(); $id = $data['id']; if ($id) { try { $insertData->load($id); $insertData->setTitle($data['title'])->save(); $response = ['success' => true, 'message' => $data]; } catch (\Exception $e) { $response = ['success' => false, 'message' => $e->getMessage()]; } } return response; } }

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88

   <?php namespace Vendor\Module\Model\Api;   use Vendor\Module\Api\CustomInterface; use Vendor\Module\Model\ModuleFactory;   class Custom implements CustomInterface {     private $moduleFactory;     private $quote;     protected $response = ['success' => false];       public function __construct(moduleFactory $moduleFactory, \Magento\Quote\Model\Quote $quote)     {         $this->quote = $quote;         $this->moduleFactory = $moduleFactory;     }       /** * GET for Post api * @param string $title * @return string */     public function getPost($title)     {         $insertData = $this->moduleFactory->create();         try {             $insertData->setTitle($data['title'])->save();             $response = ['success' => true, 'message' => $data];         } catch (\Exception $e) {             $response = ['success' => false, 'message' => $e->getMessage()];         }         return $response;     }       /** * @return string */     public function getData()     {         try {             $data = $this->moduleFactory->create()->getCollection()->getData();             return $data;         } catch (\Exception $e) {             return ['success' => false, 'message' => $e->getMessage()];         }     }       /** * @param int $id * @return bool true on success */     public function getDelete($id)     {         try {             if ($id) {                 $data = $this->moduleFactory->create()->load($id);                 $data->delete();                 return "success";             }         } catch (\Exception $e) {             $response = ['success' => false, 'message' => $e->getMessage()];         }         return "false";     }       /** * @param int $id * @return string */     public function getById($id)     {         try {             if ($id) {                 $data = $this->moduleFactory->create()->load($id)->getData();                 return ['success' => true, 'message' => json_encode($data)];             }         } catch (\Exception $e) {             return ['success' => false, 'message' => $e->getMessage()];         }     }       /** * GET for Post api * @param string $title * @return string */     public function getEdit($title)     {         $edit = file_get_contents("php://input");         $data = json_decode($edit, true);         $insertData = $this->moduleFactory->create();         $id = $data['id'];         if ($id) {             try {                 $insertData->load($id);                 $insertData->setTitle($data['title'])->save();                 $response = ['success' => true, 'message' => $data];             } catch (\Exception $e) {                 $response = ['success' => false, 'message' => $e->getMessage()];             }         }         return response;     } }

Done!

Any doubts about the above method can be mentioned in the Comments section below. I’d be happy to help.

Also, do share the post with Magento Community via social media.

Thank you.