szit

Ez az oldal csak olvasható. Megtekintheted a forrását, de nem változtathatod meg. Ha úgy gondolod, hogy ez helytelen, kérdezd az Adminisztrátorokat!
[[oktatas:programozás:java:java adatbázis:sqlite|< SQLite]]

====== SQLite ======

  * **Szerző:** Sallai András
  * Copyright (c) 2013, Sallai András
  * Szerkesztve: 2013-2024
  * Licenc: [[https://creativecommons.org/licenses/by-sa/4.0/|CC BY-SA 4.0]]
  * Web: https://szit.hu

===== Az SQLite =====

Az SQLite egy nyílt forráskódú, beágyazott SQL adatbázis-kezelő 
rendszer. A beágyazott azt jelenti, hogy nincs szükség külön 
kiszolgálóra, az alkalmazás közvetlenül éri el az adatbázist,
ami a fájlrendszerben tárolódik.

Az SQLite az adatokat egy .db vagy egy .sqlite kiterjesztésű 
fájlban tárolja.

Használati esetek:

  * mobilalkalmazás
  * asztali alkalmazás
  * webes alkalmazás
  * tesztelés és prototípus fejlesztés
  * beágyazott rendszereken (pl. IoT eszközök)

===== Adatbázis kezelése =====

==== Az sqlite3 parancs ====

Telepítés Windowson és Linuxon:
  choco install sqlite.shell
  apt install sqlite3

Ellenőrzés:
  sqlite3 --version

Leírás itt:
  * [[oktatas:adatbazis-kezeles:sqlite:shell]]

==== VSCode bővítmény ====

Telepítsük a következő bővítményt:

  * SQLite3 Editor

Az SQLite3 Editor-t közzétette: yy0931.

==== Táblák létrehozása =====

<code mysql>
create table employees (
    id integer not null primary key autoincrement,
    name text,
    city text,
    salary real
);
</code>

===== Illesztőprogram =====

Látogassuk meg a következő weboldalt:
  * https://github.com/xerial/sqlite-jdbc/releases (2024)
  * https://central.sonatype.com/artifact/org.xerial/sqlite-jdbc (2024)


Maven függőség beállítása:

<code>
<dependency>
    <groupId>org.xerial</groupId>
    <artifactId>sqlite-jdbc</artifactId>
    <version>3.46.1.3</version>
</dependency>
</code>


===== Kapcsolódás =====

<code java App.java>
import java.sql.Connection;
import java.sql.DriverManager;

public class App {
    public static void main(String[] args) throws Exception {
        String url = "jdbc:sqlite:database.sqlite";
        Connection conn = DriverManager.getConnection(url);
        System.out.println("OK");
        conn.close();
    }
}
</code>

Ha a projekt futtatásakor az illesztőprogram rendelkezésre
kell álljon. A database.sqlite fájl ha nem létezik, 
automatikusan létrejön, 0 mérettel.

===== Az SQLException =====

<code java Sqlite.java>
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

class App {
    public static void main(String[] args) {
        try {
            String url = "jdbc:sqlite:database.sqlite";
            Connection conn = DriverManager.getConnection(url);
            System.out.println("OK");
            conn.close();
        }catch(SQLException e) {
            System.err.println("Hiba! Az elérés sikertelen!");
            System.err.println(e.getMessage());        
        }
    }
}
</code>


===== Kapcsolódáshoz osztály =====

<code java Database.java>
import java.sql.Connection;

public interface Database {
    public Connection connect();
}
</code>

<code java Sqlite.java>
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Sqlite implements Database {
    @Override
    public Connection connect() {
        try {
            return tryConnect();
        }catch(SQLException e) {
            System.err.println("Hiba! Az elérés sikertelen!");
            System.err.println(e.getMessage());            
            return null;
        }
    }
    public Connection tryConnect() {
        String url = "jdbc:sqlite:database.sqlite";
        Connection conn = DriverManager.getConnection(url);
        return conn;
    }
}
</code>


===== CRUD műveletek =====

==== Adatbázistábla ====

<code mysql>
create table employees(
    id integer not null primary key autoincrement,
    name text,
    city text,
    salary real
);
</code>

==== Modell ====

<code java Employee.java>
public class Emplyoee {
    Integer id;
    String name;
    String city;
    Double salary;
}
</code>

==== Read ====

<code java DataSource.java>
import java.util.ArrayList;
import java.sql.Connection;
import java.Statement;
import java.ResultSet;

public class DataSource {
    Database database;
    public DataSource(Database database) {
        this.database = database;
    }
    public ArrayList<Employee> getEmployees() {
        try {
            tryGetEmployee();
        }catch(SQLException e) {
            System.err.println("Hiba! Az elérés sikertelen!");
            System.err.println(e.getMessage());
            
            return null;        
        }
    }
    public ArrayList<Employee> tryGetEmployee() {
        ArrayList<Employee> empList = new ArrayList<>();
        Connection conn = database.connect();
        String sql = "select * from emplyoees";
        Statement st = conn.createStatement();
        ResultSet rs = st.executeQuery(sql);
        while(rs.next()) {
            Employee emp = new Employee();
            emp.id = rs.getInt("id");
            emp.name = rs.getString("name");
            emp.city = rs.getString("city");
            emp.salary = rs.getDouble("salary");
            empList.add(emp);
        }
        return empList;
    }
}
</code>

===== PreparedStatement használata =====

==== Create művelet ====

<code java EmployeeSource.java>
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

public class EmployeeSource {
  Database datbase;
  public EmployeeSource(Database database) {
    this.datbase = database;
  }

  public ArrayList<Employee> getEmployees() {
    try {
      return tryGetEmployees();
    } catch (SQLException e) {
      System.err.println("Hiba! A lekérdezés sikertelen！");
      System.err.println(e.getMessage());
      return null;
    }
  }

  public ArrayList<Employee> tryGetEmployees() throws SQLException {
    Connection conn = datbase.connect();
    String sql = "select * from employees";
    ArrayList<Employee> employees = new ArrayList<Employee>();
    Statement stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery(sql);
    while (rs.next()) {
      Employee employee = new Employee();
      employee.id = rs.getInt("id");
      employee.name = rs.getString("name");
      employee.city = rs.getString("city");
      employee.salary = rs.getDouble("salary");
      employees.add(employee);
    }
    return employees;    
  }

  public Employee addEmployee(Employee employee) {
    try {
      return tryAddEmployee(employee);
    } catch (SQLException e) {
      System.err.println("Hiba! A hozzáadás sikertelen！");
      System.err.println(e.getMessage());
      return null;
    }
  }

  public Employee tryAddEmployee(Employee employee) throws SQLException {
    Connection conn = datbase.connect();
    String sql = """
    insert into employees 
    (name, city, salary) 
    values 
    (?, ?, ?)
    """;
    PreparedStatement pstmt = conn.prepareStatement(sql);
    pstmt.setString(1, employee.name);
    pstmt.setString(2, employee.city);
    pstmt.setDouble(3, employee.salary);
    pstmt.executeUpdate();
    return employee;
  }
}
</code>

==== Frissítés ====

Adjuk az EmployeeSource osztályhoz:

<code java>
  public Employee updateEmployee(Employee employee) {
    try {
      return tryUpdateEmployee(employee);
    } catch (SQLException e) {
      System.err.println("Hiba! A frissítés sikertelen！");
      System.err.println(e.getMessage());
      return null;
    }
  }

  public Employee tryUpdateEmployee(Employee employee) 
  throws SQLException {
    Connection conn = datbase.connect();
    String sql = """
    update employees 
    set name = ?, city = ?, salary = ? 
    where id = ?
    """;
    PreparedStatement pstmt = conn.prepareStatement(sql);
    pstmt.setString(1, employee.name);
    pstmt.setString(2, employee.city);
    pstmt.setDouble(3, employee.salary);
    pstmt.setInt(4, employee.id);
    pstmt.executeUpdate();
    return employee;
  }
</code>

==== Törlés ====

Adjuk az EmployeeSource osztályhoz:

<code java>
  public void deleteEmployee(int id) {
    try {
      tryDeleteEmployee(id);
    } catch (SQLException e) {
      System.err.println("Hiba! A törleés sikertelen！");
      System.err.println(e.getMessage());
    }
  } 

  public void tryDeleteEmployee(int id) 
  throws SQLException {
    Connection conn = datbase.connect();
    String sql = "delete from employees where id = ?";
    PreparedStatement pstmt = conn.prepareStatement(sql);
    pstmt.setInt(1, id);
    pstmt.executeUpdate();
  }
</code>

===== Linkek =====

Irodalom:
  * https://www.sqlitetutorial.net/sqlite-java/ (2024)
  * https://sqlite.org/ (2024)

Szoftverek:
  * https://sqlitestudio.pl/ (2024)
  * https://sqlitebrowser.org/ (2024)