begin implementing sql connection pool (bruh)

This commit is contained in:
mykola2312 2024-04-19 08:07:53 +03:00
parent 0c6da66529
commit 5ff35527a2
4 changed files with 56 additions and 1 deletions

12
pom.xml
View file

@ -76,6 +76,18 @@
<artifactId>slf4j-api</artifactId> <artifactId>slf4j-api</artifactId>
<version>2.0.13</version> <version>2.0.13</version>
</dependency> </dependency>
<!-- DX -->
<dependency>
<groupId>org.checkerframework</groupId>
<artifactId>checker</artifactId>
<version>3.42.0</version>
</dependency>
<dependency>
<groupId>org.checkerframework</groupId>
<artifactId>checker-qual</artifactId>
<version>3.42.0</version>
</dependency>
</dependencies> </dependencies>
<build> <build>

View file

@ -1,6 +1,7 @@
package com.mykola2312.mptv; package com.mykola2312.mptv;
import com.mykola2312.mptv.config.Config; import com.mykola2312.mptv.config.Config;
import com.mykola2312.mptv.db.DB;
import com.mykola2312.mptv.ui.MainFrame; import com.mykola2312.mptv.ui.MainFrame;
import org.apache.commons.cli.*; import org.apache.commons.cli.*;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;

View file

@ -1,4 +1,4 @@
package com.mykola2312.mptv; package com.mykola2312.mptv.db;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;

View file

@ -0,0 +1,42 @@
package com.mykola2312.mptv.db;
import org.checkerframework.checker.nullness.qual.*;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.LinkedList;
import org.jooq.ConnectionProvider;
import org.jooq.exception.DataAccessException;
// I can't believe that in 2024 I have to do it myself
public class DBPool implements ConnectionProvider {
private String url;
private String user;
private String password;
public static final int POOL_LIMIT = 4;
private LinkedList<Connection> connections;
public DBPool(String url, String user, String password) {
this.url = url;
this.user = user;
this.password = password;
connections = new LinkedList<Connection>();
}
protected Connection spawnConnection() throws SQLException {
return null;
}
@Override
public @Nullable Connection acquire() throws DataAccessException {
throw new UnsupportedOperationException("Unimplemented method 'acquire'");
}
@Override
public void release(Connection arg0) throws DataAccessException {
throw new UnsupportedOperationException("Unimplemented method 'release'");
}
}