ImAlpha/HobbyProject
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add read method for data access

Browse Source
This commit is contained in:
Alatreon 2021-12-05 16:09:23 -08:00
parent 13204721b2
commit 012af8f5d7
2 changed files with 44 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Source Code/TeamHobby.HobbyProjectGenerator.Archive/Contracts/IDataSource.cs
View File

@ -16,9 +16,9 @@ namespace TeamHobby.HobbyProjectGenerator.Archive
bool WriteData(string cmd); bool WriteData(string cmd);
//Method for deleteing data from a data source, 0 for successful //Method for deleteing data from a data source, 0 for successful
bool DeleteData(); bool DeleteData(string cmd);
// Method for updating data from a data source, 0 for sucessful // Method for updating data from a data source, 0 for sucessful
bool UpdateData(); bool UpdateData(string cmd);
} }
} }

51
Source Code/TeamHobby.HobbyProjectGenerator.Archive/Implementations/SQLSource.cs
View File

@ -12,31 +12,41 @@ namespace TeamHobby.HobbyProjectGenerator.Archive
{ {
public class SQLSource : IDataSource, IRelationArchivable public class SQLSource : IDataSource, IRelationArchivable
{ {
//private SqlConnection conn; private SqlConnection conn;
//public SQLSource(string info) public SQLSource(string info)
//{ {
// conn = new SqlConnection(info); // Do I put using here to make sure the connection closed once the object is gone?
//} conn = new SqlConnection(info);
// Perhaps open the connection here?
// conn.Open();
}
public bool DeleteData() public bool DeleteData()
{ {
throw new NotImplementedException(); throw new NotImplementedException();
} }
// Makre sure to Check for instanceof() before casting to a SQLReader in the controller
public Object ReadData(string cmd) public Object ReadData(string cmd)
{ {
try try
{ {
// conn.open(); conn.Open();
//SqlCommand command = new SqlCommand(null, conn);
SqlCommand command = new SqlCommand(cmd, conn);
// conn.Execute(); // conn.Execute();
Console.WriteLine("Access a SQL database"); Console.WriteLine("Access a SQL database");
Console.WriteLine("Select * from archive"); Console.WriteLine("Select * from archive");
// Execute the command to query the data
using SqlDataReader sqlReader = command.ExecuteReader();
// while (myReader) // while (myReader)
// Print to console // Print to console
// conn.close(); conn.Close();
return null; return sqlReader;
} }
catch (Exception e) catch (Exception e)
{ {
@ -45,7 +55,7 @@ namespace TeamHobby.HobbyProjectGenerator.Archive
} }
} }
public bool UpdateData() public bool UpdateData(string cmd)
{ {
throw new NotImplementedException(); throw new NotImplementedException();
} }
@ -92,5 +102,28 @@ namespace TeamHobby.HobbyProjectGenerator.Archive
} }
} }
public Object ReadPreparedStmt(string table){
conn.Open();
//SqlCommand command = new SqlCommand(null, conn);
SqlCommand command = new SqlCommand("SELECT * from @table;", conn);
SqlParameter tableParam = new SqlParameter("@table", System.Data.SqlDbType.Text, 50);
tableParam.Value = table;
command.Parameters.Add(tableParam);
// conn.Execute();
Console.WriteLine("Access a SQL database");
Console.WriteLine("Select * from archive");
// Make the Prepare statement and excute the query:
command.Prepare();
SqlDataReader sqlReader = command.ExecuteReader();
// while (myReader)
// Print to console
// conn.close();
return sqlReader;
}
} }
} }