Skip to content

Commit f86b96d

Browse files
uurdevuurdev
committed
edited connection parameters
call static function
1 parent 34cc176 commit f86b96d

5 files changed

Lines changed: 19 additions & 20 deletions

File tree

‎db-example/src/main/java/config/DbConnectionManagement.java‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,6 @@ public static Connection connectToDatabase() {
1414
try {
1515
Class.forName(DbConnectionConfigParam.getJdbcDriver());
1616
dbConnection = DriverManager.getConnection(DbConnectionConfigParam.getDbHost(), DbConnectionConfigParam.getDbUsername(), DbConnectionConfigParam.getDbUserPassword());
17-
18-
if (dbConnection != null) {
19-
System.out.println("Veritabanına baglanıldı");
20-
} else {
21-
System.out.println("Veritabanına erişim hatalı");
22-
}
2317
} catch (Exception e) {
2418
e.printStackTrace();
2519
}

‎db-example/src/main/java/query/DeleteQueryApi.java‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,18 @@
11
package query;
22

3+
import config.DbConnectionManagement;
4+
35
import java.sql.Connection;
46
import java.sql.PreparedStatement;
57

68
public class DeleteQueryApi {
79

810

9-
public static void deleteRecord(int recordId, Connection connection) {
11+
public static void deleteRecord(int recordId) {
1012
try {
11-
PreparedStatement preparedStatement = connection.prepareStatement("DELETE FROM employee WHERE id= ?");
13+
PreparedStatement preparedStatement = DbConnectionManagement.connectToDatabase().prepareStatement("DELETE FROM employee WHERE id= ?");
1214

13-
if (SelectQueryApi.findByEmployeeId(recordId, connection) != null) {//bu recordId'de kayıt varsa eğer
15+
if (SelectQueryApi.findByEmployeeId(recordId) != null) {//bu recordId'de kayıt varsa eğer
1416
preparedStatement.setInt(1, recordId);
1517
int deleteRowCount = preparedStatement.executeUpdate();
1618
System.out.println(deleteRowCount + "rows deleted !");

‎db-example/src/main/java/query/InsertQueryApi.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package query;
22

3+
import config.DbConnectionManagement;
34
import entity.Employee;
45
import validate.ConnectionValidate;
56

@@ -13,16 +14,16 @@ public class InsertQueryApi {
1314
/*
1415
Bu fonksiyon dışarıdan parametre olarak verılmıs olan kullanıcıyı veritabanına kayıt eder
1516
*/
16-
public static void insertOneRecord(Employee employee, Connection connection) {
17+
public static void insertOneRecord(Employee employee) {
1718
try {
1819
if (employee != null) {//gönderilen kaydın boş olup olmamasına bakıldı
19-
if (ConnectionValidate.validateConnection(connection)) {//baglantının basarılı ıle true
20-
PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO employee (id,name,lastName,gender,birthDate,hireDate) VALUES (?,?,?,?,?,?)");
20+
if (ConnectionValidate.validateConnection(DbConnectionManagement.connectToDatabase())) {//baglantının basarılı ıle true
21+
PreparedStatement preparedStatement = DbConnectionManagement.connectToDatabase().prepareStatement("INSERT INTO employee (id,name,lastName,gender,birthDate,hireDate) VALUES (?,?,?,?,?,?)");
2122
/*
2223
TODO burada son kayıdı bulup idsini alıp yenı kayıt ekleren son kaydın id'sini +1 yapmak gereklı auto +1 yükselicek her personel kaydı
2324
*/
2425
//son eklenen kaydın ıdsını aldı 1 arttırıp yeni kayıt oluşturdu
25-
preparedStatement.setLong(1, SelectQueryApi.resultLastRecordId(connection) + 1);
26+
preparedStatement.setLong(1, SelectQueryApi.resultLastRecordId() + 1);
2627

2728
preparedStatement.setString(2, employee.getName());
2829
preparedStatement.setString(3, employee.getLastName());

‎db-example/src/main/java/query/SelectQueryApi.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package query;
22

3+
import config.DbConnectionManagement;
34
import entity.Employee;
45
import validate.ConnectionValidate;
56

@@ -15,10 +16,10 @@ public class SelectQueryApi {
1516
bu fonksiyon dışarıdan gelen tablo içindeki en son kaydın recordId'sını döner
1617
fonksiyonun yazılma nedeni kayıt eklenirken son id'li kaydın recordId'sını 1 arttırabılmek için
1718
*/
18-
public static int resultLastRecordId(Connection connection) {
19+
public static int resultLastRecordId() {
1920
int lastId = 0;
2021
try {
21-
Statement statement = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
22+
Statement statement = DbConnectionManagement.connectToDatabase().createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
2223
ResultSet resultSet = statement.executeQuery("SELECT id FROM employee");
2324
resultSet.last();
2425
lastId = resultSet.getInt(1);
@@ -37,10 +38,10 @@ public static int resultLastRecordId(Connection connection) {
3738
2-> Kayıt eklerken aynı id'de kayıt olabilir bu seferde hata alırız ve kayıt ekleyemeyebiliriz
3839
3-> Kayıt güncellerken o kaydın olup olmadığı önemlidir sonuçta kayıt yoksa eğer güncelleme işlemi yapılmaz o kaydın ılk eklenmesi gerekir
3940
*/
40-
public static Integer findByEmployeeId(int id, Connection connection) {
41+
public static Integer findByEmployeeId(int id) {
4142
Integer recordId = null;
4243
try {
43-
PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM employee WHERE id= ?");
44+
PreparedStatement preparedStatement = DbConnectionManagement.connectToDatabase().prepareStatement("SELECT * FROM employee WHERE id= ?");
4445
preparedStatement.setInt(1, id);
4546
ResultSet resultSet = preparedStatement.executeQuery();
4647
if (resultSet.next()) {

‎db-example/src/main/java/query/UpdateQueryApi.java‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package query;
22

3+
import config.DbConnectionManagement;
34
import entity.Employee;
45

56
import java.sql.Connection;
@@ -8,13 +9,13 @@
89

910
public class UpdateQueryApi {
1011

11-
public static void updateRecord(Employee employee, Connection connection) {
12+
public static void updateRecord(Employee employee) {
1213
try {
1314

1415
//employee id'de kayıt varsa eğer guncelleme işlemi yapılıcak
15-
if (SelectQueryApi.findByEmployeeId(employee.getId().intValue(), connection) != null) {
16+
if (SelectQueryApi.findByEmployeeId(employee.getId().intValue()) != null) {
1617
PreparedStatement preparedStatement =
17-
connection.prepareStatement("UPDATE employee SET name = ?, lastName = ?, gender = ?, birthDate= ?,hireDate= ? WHERE id = ? ");
18+
DbConnectionManagement.connectToDatabase().prepareStatement("UPDATE employee SET name = ?, lastName = ?, gender = ?, birthDate= ?,hireDate= ? WHERE id = ? ");
1819

1920
preparedStatement.setString(1, employee.getName());
2021
preparedStatement.setString(2, employee.getLastName());

0 commit comments

Comments
 (0)