Adisri99 commited on
Commit
922da09
·
verified ·
1 Parent(s): e4f17b3

Update backend/app/repositories/dataset_repo.py

Browse files
backend/app/repositories/dataset_repo.py CHANGED
@@ -1,12 +1,31 @@
1
  from sqlalchemy.orm import Session
2
  from backend.app.models.dataset import Dataset
3
 
4
- def create_dataset(db: Session, **kwargs) -> Dataset:
5
- obj = Dataset(**kwargs)
6
- db.add(obj)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
7
  db.commit()
8
- db.refresh(obj)
9
- return obj
 
10
 
11
  def get_dataset(db: Session, dataset_id: str) -> Dataset | None:
12
- return db.query(Dataset).filter(Dataset.id == dataset_id).first()
 
1
  from sqlalchemy.orm import Session
2
  from backend.app.models.dataset import Dataset
3
 
4
+
5
+ def create_dataset(
6
+ db: Session,
7
+ id: str,
8
+ name: str,
9
+ file_path: str,
10
+ row_count: int,
11
+ column_count: int,
12
+ schema_json: str,
13
+ profile_json: str,
14
+ ) -> Dataset:
15
+ dataset = Dataset(
16
+ id=id,
17
+ name=name,
18
+ file_path=file_path,
19
+ row_count=row_count,
20
+ column_count=column_count,
21
+ schema_json=schema_json,
22
+ profile_json=profile_json,
23
+ )
24
+ db.add(dataset)
25
  db.commit()
26
+ db.refresh(dataset)
27
+ return dataset
28
+
29
 
30
  def get_dataset(db: Session, dataset_id: str) -> Dataset | None:
31
+ return db.query(Dataset).filter(Dataset.id == dataset_id).first()