Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
F
fastAPI_task
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
ajil.k
fastAPI_task
Commits
fc776ec4
Commit
fc776ec4
authored
Feb 06, 2023
by
ajil.k
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
updated
parent
86dcae83
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
12 additions
and
11 deletions
+12
-11
scripts/constants/db_connection.py
+2
-4
scripts/core/handlers/api_functions.py
+7
-2
scripts/core/handlers/insert_data_into_db.py
+3
-5
No files found.
scripts/constants/db_connection.py
View file @
fc776ec4
...
@@ -11,9 +11,7 @@ def db_connect():
...
@@ -11,9 +11,7 @@ def db_connect():
# Create a database
# Create a database
db_name
=
'db_person'
db_name
=
'db_person'
db
=
connection
[
db_name
]
db
=
connection
[
db_name
]
collection_name
=
'personal_details'
print
(
"Database connected successfully!"
)
collection
=
db
[
collection_name
]
return
db
print
(
"Database Connected Successfully !"
)
return
collection
except
Exception
as
e
:
except
Exception
as
e
:
print
(
"Error "
,
e
)
print
(
"Error "
,
e
)
scripts/core/handlers/api_functions.py
View file @
fc776ec4
...
@@ -11,7 +11,9 @@ connect(db='db_person', host='localhost', port=27017)
...
@@ -11,7 +11,9 @@ connect(db='db_person', host='localhost', port=27017)
class
operations_on_api
:
class
operations_on_api
:
def
__init__
(
self
):
def
__init__
(
self
):
self
.
collection
=
db_connect
()
self
.
db
=
db_connect
()
collection_name
=
'personal_details'
self
.
collection
=
self
.
db
[
collection_name
]
def
insert_all_data
(
self
):
def
insert_all_data
(
self
):
try
:
try
:
...
@@ -43,7 +45,7 @@ class operations_on_api:
...
@@ -43,7 +45,7 @@ class operations_on_api:
phone_no
=
details
.
phone_no
)
phone_no
=
details
.
phone_no
)
result
=
self
.
collection
.
insert_one
(
dict
(
person_details
))
result
=
self
.
collection
.
insert_one
(
dict
(
person_details
))
if
result
:
if
result
:
print
(
"Data inserted to the document"
,
dict
(
person_details
))
print
(
"Data inserted to the document
\n
"
,
dict
(
person_details
))
return
result
return
result
except
Exception
as
e
:
except
Exception
as
e
:
print
(
"Data insertion error-"
,
e
)
print
(
"Data insertion error-"
,
e
)
...
@@ -61,6 +63,7 @@ class operations_on_api:
...
@@ -61,6 +63,7 @@ class operations_on_api:
if
update_details
.
phone_no
is
not
None
:
if
update_details
.
phone_no
is
not
None
:
set_data
[
"$set"
][
"phone_no"
]
=
update_details
.
phone_no
set_data
[
"$set"
][
"phone_no"
]
=
update_details
.
phone_no
result
=
self
.
collection
.
update_one
(
condition_data
,
set_data
)
result
=
self
.
collection
.
update_one
(
condition_data
,
set_data
)
print
(
"Updated Data:
\n
"
,
set_data
[
"$set"
])
return
result
return
result
except
Exception
as
e
:
except
Exception
as
e
:
print
(
"Data updation error-"
,
e
)
print
(
"Data updation error-"
,
e
)
...
@@ -68,7 +71,9 @@ class operations_on_api:
...
@@ -68,7 +71,9 @@ class operations_on_api:
def
delete_one_document
(
self
,
document_id
):
def
delete_one_document
(
self
,
document_id
):
try
:
try
:
condition_data
=
{
"id"
:
document_id
}
condition_data
=
{
"id"
:
document_id
}
document
=
self
.
collection
.
find_one
(
condition_data
)
result
=
self
.
collection
.
delete_one
(
condition_data
)
result
=
self
.
collection
.
delete_one
(
condition_data
)
print
(
"Deleted document details:
\n
"
,
document
)
return
result
return
result
except
Exception
as
e
:
except
Exception
as
e
:
print
(
"Data deletion error-"
,
e
)
print
(
"Data deletion error-"
,
e
)
scripts/core/handlers/insert_data_into_db.py
View file @
fc776ec4
from
scripts.constants.app_configuration
import
csv_path
from
scripts.core.handlers.read_file
import
extract_data
def
insert_into_db
(
collection
,
data
):
def
insert_into_db
(
collection
,
data
):
try
:
status
=
collection
.
insert_many
(
data
)
status
=
collection
.
insert_many
(
data
)
if
status
:
if
status
:
return
True
return
True
else
:
else
:
return
False
return
False
except
Exception
as
e
:
print
(
"Data insertion to db error-"
,
e
)
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment