Spring Boot Veritabanı Bağlantı ve Ekleme İşlemleri

Spring boot da öncelikle veritabanı bağlantısı yapacağımız projemizi https://start.spring.io/ üzerinden düzgün bir şekilde yapılandırmalıyız. Burada ben MySql veritabanını kullanacağım için addDependencies MySql veritabanını ekledim.

Bu projeyi generate ettikten sonra kurulumu dosyaya çıkarıp kullanmaya başlayabiliriz. Şimdide MySql kurulumuna geçelim. MySql veritabanını https://dev.mysql.com/downloads/installer/ buradan indirebilirsin indirdiğinizde bazı installer ayarları var biz Spring bootda kullanacağımız sadece bazı kurulumları yapacağız. Burada ki Connector/J java da bağlantı kurmak için gerekli.

Daha sonra bu connector J nin kurulu olduğu yeri File Project Structure kısmından Jars or directory add yapıp eklemeyi sağlayacağız. Uygulamamızın kurulumunda oluşturduğumuz veritabanı bilgilerini resources klasörü altında applicatio.properties klasöründe tanımlayacağız. spring.datasource.url=jdbc:mysql://localhost:3306/ulkeler?useSSL=false spring.datasource.username=root spring.datasource.password=123456 spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.url=jdbc:mysql://localhost:3306/ulkeler?useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

Örnek olarak size bir tanımlama veriyorum. Bu veritabanında ki configuration ayarlarını ve bağlantıyı çağırmak için bir DbHelper classı oluşturup burada DataSource kullanıyoruz.

@Configuration
public class DbHelper { //database bağlantı işlemleri yapılıyor
    @Autowired
    private DataSource dataSource; //application.properties tanımladığımız özellikleri çağırır

    public Connection getConnection() {
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }

}

Daha sonrasında ekleme işlemleri için veritabanı schema oluşturup tablonun column belirlemeliyiz. Burada size örnek bir veritabanına ekleme işlemi gönderiyorum. DbHelper helper = new DbHelper(); Connection connection = helper.getConnection(); //dbhelper methodu bağlantı yapmamızı sağlıyoruz PreparedStatement stmt = null; //SQL ifadesini veritabanına göndermeden önce oluşturulması ve önceden derlenmesi için kullanılan bir arayüzdür.

DbHelper helper = new DbHelper();
Connection connection = helper.getConnection(); //dbhelper methodu bağlantı yapmamızı sağlıyoruz
PreparedStatement stmt = null; //SQL ifadesini veritabanına göndermeden önce oluşturulması ve önceden derlenmesi için kullanılan bir arayüzdür.
String sql = Queries.COUNTRY_ADD; //ekleme sorgusu
stmt = connection.prepareStatement(sql);
stmt.setString(1,countryCode);
stmt.setString(2, country.getName());
stmt.setString(3, country.getNativeName());
stmt.setInt(4, country.getPhone());
stmt.setString(5, country.getContinent());
stmt.setString(6, country.getCapital());
stmt.setString(7, country.getCurrency());
stmt.executeUpdate(); //günceller verilene göre

Burada insertCountries methodunu yazmış bulunuyoruz. Burada kullandığımız Queries bir classdır içerisinde ekleme methodu bulunmaktadır.

public static final String COUNTRY_ADD = "INSERT INTO country (id,name, nativeName, phone, continent, capital, currency) " +
            "VALUES (?, ?, ?, ?, ?, ?, ?)"; //database ülke ekleme query

Bu methoda ek olarak birde veritabanı modellerimizi tanımlamalayız CountryModel altında bu model bizim tablomuzun her sütununu ifade eder.

@Getter
@Setter
public class Country {

    private String  id;
    private String name;
    private String nativeName;
    private int phone;
    private String continent;
    private String capital;
    private String currency;


    // Getters and setters
    @ConstructorProperties({"id","name", "native", "phone", "continent", "capital", "currency"})
    public Country(String id, String name, String nativeName, int phone, String continent, String capital, String currency) {
        this.id =id;
        this.name = name;
        this.nativeName =  nativeName;
        this.phone = phone;
        this.continent = continent;
        this.capital = capital;
        this.currency = currency;
    }

    public Country() {

    }
}

Şimdi main methodumuzu oluşturup bu tabloya eklemeyi yapalım.

DatabaseManager databaseManager = new DatabaseManager();
databaseManager.insertCountries("AG","Antigua and Barbuda","Antigua and Barbuda","1268","NA","Saint John's","XCD");

Burada ilk verimizi database de veritabanımıza eklemiş olduk.

Bu yazımızda özet olarak spring boot veritabanı projesi oluşturmayı MySql veritabanı kurup bir veritabanı oluşturup veritabanına veri eklemeyi gösterdim. Esenlikler…