Main

.github/workflows/azure-static-web-apps-ashy-bush-008b90a10.yml

@@ -0,0 +1,46 @@
+name: Azure Static Web Apps CI/CD
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    types: [opened, synchronize, reopened, closed]
+    branches:
+      - main
+
+jobs:
+  build_and_deploy_job:
+    if: github.event_name == 'push' || (github.event_name == 'pull_request' && github.event.action != 'closed')
+    runs-on: ubuntu-latest
+    name: Build and Deploy Job
+    steps:
+      - uses: actions/checkout@v3
+        with:
+          submodules: true
+          lfs: false
+      - name: Build And Deploy
+        id: builddeploy
+        uses: Azure/static-web-apps-deploy@v1
+        with:
+          azure_static_web_apps_api_token: ${{ secrets.AZURE_STATIC_WEB_APPS_API_TOKEN_ASHY_BUSH_008B90A10 }}
+          repo_token: ${{ secrets.GITHUB_TOKEN }} # Used for Github integrations (i.e. PR comments)
+          action: "upload"
+          ###### Repository/Build Configurations - These values can be configured to match your app requirements. ######
+          # For more information regarding Static Web App workflow configurations, please visit: https://aka.ms/swaworkflowconfig
+          app_location: "." # App source code path
+          api_location: "api" # Api source code path - optional
+          output_location: "build" # Built app content directory - optional
+          ###### End of Repository/Build Configurations ######
+
+  close_pull_request_job:
+    if: github.event_name == 'pull_request' && github.event.action == 'closed'
+    runs-on: ubuntu-latest
+    name: Close Pull Request Job
+    steps:
+      - name: Close Pull Request
+        id: closepullrequest
+        uses: Azure/static-web-apps-deploy@v1
+        with:
+          azure_static_web_apps_api_token: ${{ secrets.AZURE_STATIC_WEB_APPS_API_TOKEN_ASHY_BUSH_008B90A10 }}
+          action: "close"

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+    "githubPullRequests.ignoredPullRequestBranches": [
+        "main"
+    ]
+}

app.py

@@ -1,21 +1,171 @@
-import os
+import os, uuid
+import pandas as pd
+
+import pymssql
+from azure.identity import DefaultAzureCredential
+from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient
+import datetime
 
 from flask import (Flask, redirect, render_template, request,
-                   send_from_directory, url_for)
+                   send_from_directory, url_for, session)
 
 app = Flask(__name__)
+# app.secret_key = os.urandom(24)
+
+# conn = pymssql.connect(host='bonjour.database.windows.net' ,user='zander' ,password = 'KB24ts1989',database='Mavs')
+# cur = conn.cursor()
+#================================================================================================
+# # Create a blob client using the local simulator
+# try:
+#     account_url = "https://sinong.blob.core.windows.net"
+#     default_credential = DefaultAzureCredential()
 
+#     # Create the BlobServiceClient object
+#     blob_service_client = BlobServiceClient(account_url, credential=default_credential)
+#     container_client = blob_service_client.get_container_client(container="quiz0")
+#     blob_list = container_client.list_blobs()
+#     for blob in blob_list:
+#         print("\t" + blob.name)
+# except:
+#     print("Error creating the BlobServiceClient object")
+#================================================================================================
 
 @app.route('/')
 def index():
    print('Request for index page received')
    return render_template('index.html')
 
+
+# @app.route('/test')
+# def test():
+#     SQL_QUERY = """
+#                 SELECT 
+#                 TOP 5 c.CustomerID, 
+#                 c.CompanyName, 
+#                 COUNT(soh.SalesOrderID) AS OrderCount 
+#                 FROM 
+#                 SalesLT.Customer AS c 
+#                 LEFT OUTER JOIN SalesLT.SalesOrderHeader AS soh ON c.CustomerID = soh.CustomerID 
+#                 GROUP BY 
+#                 c.CustomerID, 
+#                 c.CompanyName 
+#                 ORDER BY 
+#                 OrderCount DESC;
+#                 """
+#     cur.execute(SQL_QUERY)
+#     data = cur.fetchall()
+#     print('Request for test page received')
+#     return render_template('test.html', data=data)
+
+
+# @app.route('/assignment1')
+# def assignment1():
+#     data_file_path = os.path.join(app.root_path, 'static', 'data', 'people.csv')
+#     data = pd.read_csv(data_file_path)
+#     print('Request for assignment1 page received')
+
+#     return render_template('assignment1.html', contain_content=False, table_content=list(data.values.tolist()), titles=data.columns.values)
+
+
+# @app.route('/assignment2')
+# def assignment2():
+
+#     print('Request for assignment1 page received')
+#     data = None
+#     headers = None
+#     return render_template('assignment2.html', contain_content=False, table_content=data, titles=headers)
+
+
+# @app.route('/a1-upload', methods = ['POST'])   
+# def upload():   
+#     if request.method == 'POST':   
+#         f = request.files['file']
+#         file_path = os.path.join(app.root_path, 'uploads', f.filename)
+#         session['file_path'] = file_path
+#         f.save(file_path)
+
+#         data = pd.read_csv(file_path)
+
+#         for idx, (_, row) in enumerate(data.iterrows()):
+#             sql_query = f"INSERT INTO dbo.Quiz1 VALUES ('{idx}', "
+#             for element in row:
+#                 if pd.isna(element):
+#                     element = 'NULL'
+#                     sql_query += f"{element},"
+#                 else:
+#                     sql_query += f"'{element}',"
+#             sql_query = sql_query[:-1] + ");"
+#             print(sql_query)
+#             cur.execute(sql_query)
+
+#         conn.commit()
+#         return render_template('assignment1.html', contain_content=False, table_content=list(data.values.tolist()), titles=data.columns.values)
+
+
+# @app.route('/a1-searchbyname', methods = ['POST', 'GET'])
+# def a1_searchbyname():
+#     name = request.form.get('queryName')
+#     data_file_path = session.get('file_path')
+#     data = pd.read_csv(data_file_path)
+#     query_data = data.loc[data['name'] == name]
+#     print(name, query_data)
+#     for col in query_data.columns:
+#             query_data[col].fillna(f"no {col} available", inplace=True)
+#     return render_template('assignment1.html', contain_content=True, table_content=list(query_data.values.tolist()), titles=query_data.columns.values)
+
+# @app.route('/a1-searchbycostrange', methods = ['POST', 'GET'])
+# def a1_searchbycostrange():
+#     min_cost = request.form.get('minCost')
+#     max_cost = request.form.get('maxCost')
+#     data_file_path = session.get('file_path')
+#     data = pd.read_csv(data_file_path)
+#     query_data = data.loc[(data['cost'].astype(float) >= int(min_cost)) & (data['cost'].astype(float) <= int(max_cost))]
+#     print(min_cost, max_cost, query_data)
+#     for col in query_data.columns:
+#             query_data[col].fillna(f"no {col} available", inplace=True)
+#     return render_template('assignment1.html', contain_content=True, table_content=list(query_data.values.tolist()), titles=query_data.columns.values)
+
+
+# @app.route('/a2-searchbymag', methods = ['POST', 'GET'])
+# def a2_searchbymag():
+#     min_mag = request.form.get('minMag')
+#     max_mag = request.form.get('maxMag')
+#     back_day = request.form.get('backDay')
+
+#     # query header from database
+#     SQL_QUERY_TITLE = """select COLUMN_NAME
+#                         from INFORMATION_SCHEMA.COLUMNS
+#                         where TABLE_NAME='earthquakes';"""
+#     cur.execute(SQL_QUERY_TITLE)
+#     headers = cur.fetchall()
+
+#     # query data from database
+#     # Get today's datetime
+#     today = datetime.datetime.now()
+
+#     # Modify the query to query for the latest back_day data
+#     SQL_QUERY = f"""
+#                 SELECT 
+#                 * 
+#                 FROM 
+#                 ass1.earthquakes 
+#                 WHERE 
+#                 mag >= {min_mag} AND mag <= {max_mag} AND time >= DATEADD(day, -{back_day}, GETDATE());
+#                 """
+#     cur.execute(SQL_QUERY)
+#     data = cur.fetchall()
+#     print(type(headers))
+#     print(type(data))
+
+#     return render_template('assignment2.html', contain_content=True, table_content=data, titles=headers)
+
+
 @app.route('/favicon.ico')
 def favicon():
     return send_from_directory(os.path.join(app.root_path, 'static'),
                                'favicon.ico', mimetype='image/vnd.microsoft.icon')
 
+
 @app.route('/hello', methods=['POST'])
 def hello():
    name = request.form.get('name')

requirements.txt

@@ -1,3 +1,6 @@
 Flask==2.2.2
 gunicorn
 Werkzeug==2.2.2
+Pandas==2.2.2
+azure-storage-blob
+azure-identity