diff --git a/src/dao/ProductDAO.java b/src/dao/ProductDAO.java
index 1921264..e922477 100644
--- a/src/dao/ProductDAO.java
+++ b/src/dao/ProductDAO.java
@@ -3,10 +3,7 @@ package dao;
 import model.Product;
 import utils.MysqlConnect;
 
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
+import java.sql.*;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -41,4 +38,27 @@ public class ProductDAO {
 
         return result;
     }
+
+    public Boolean createNewProduct(String name, Double price, String title, Date date, String catelog, Boolean status) throws SQLException {
+       String sql = "INSERT INTO `products` (`id`, `name`, `price`, `title`, `created`, `catalog`, `status`) VALUES (NULL, ?, ?, ?, ?, ?, ?);";
+
+       Connection c = MysqlConnect.getConnecton();
+
+       PreparedStatement ps = c.prepareStatement(sql);
+
+       ps.setString(1, name);
+       ps.setDouble(2, price);
+       ps.setString(3, title);
+       ps.setDate(4, date);
+       ps.setString(5, catelog);
+       ps.setBoolean(6, status);
+
+       int rows = ps.executeUpdate();
+
+       if(rows > 0) {
+           return true;
+       }
+
+       return false;
+    }
 }
diff --git a/src/menus/ProductMgMenu.java b/src/menus/ProductMgMenu.java
index c3140b0..7a48125 100644
--- a/src/menus/ProductMgMenu.java
+++ b/src/menus/ProductMgMenu.java
@@ -31,6 +31,10 @@ public class ProductMgMenu {
                     ps.showProductList();
                     System.out.println("DSSP");
                     break;
+                case 2:
+                    System.out.println("thêm sản phẩm");
+                    ps.addProduct();
+                    break;
                 default:
                     System.out.println("Lựa chọn kg phù hợp!");
             }
diff --git a/src/services/ProductService.java b/src/services/ProductService.java
index 99b9a9a..1960832 100644
--- a/src/services/ProductService.java
+++ b/src/services/ProductService.java
@@ -2,6 +2,12 @@ package services;
 
 import dao.ProductDAO;
 
+import java.sql.Date;
+import java.sql.SQLException;
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.util.Scanner;
+
 public class ProductService {
     ProductDAO productDAO = new ProductDAO();
 
@@ -13,4 +19,33 @@ public class ProductService {
         }
     }
 
+    public void addProduct() {
+        Scanner sc = new Scanner(System.in);
+        System.out.println("Nhập tên sản phẩm");
+        String name = sc.nextLine();
+        System.out.println("Nhập giá bán");
+        Double price = sc.nextDouble();
+        System.out.println("Nhập tiêu đề sản phẩm");
+        String title = sc.nextLine();
+        System.out.println("Ngày tạo");
+        Date created = Date.valueOf(LocalDate.now());
+        System.out.println("Danh mục");
+        String catalog = sc.nextLine();
+        System.out.println("Nhập trạng thái");
+        Boolean status  = sc.nextBoolean();
+        System.out.println("created" + created);
+
+        try {
+            if(productDAO.createNewProduct(name, price, title, created, catalog, status)) {
+                System.out.println("thêm sp thành công!");
+            }else {
+                System.out.println("Thêm sp thất bại");
+            }
+        }catch (SQLException e) {
+            System.out.println("E" + e);
+            System.out.println("lỗi xử lý CSDL");
+        }
+
+    }
+
 }