<dependency>
<groupId>com.j256.ormlite</groupId>
<artifactId>ormlite-core</artifactId>
<version>5.5</version>
</dependency>
import com.j256.ormlite.jdbc.JdbcConnectionSource;
import com.j256.ormlite.support.ConnectionSource;
import java.sql.SQLException;
public class DatabaseConfig {
private static final String DATABASE_URL = "jdbc:mysql://localhost:3306/mydatabase";
private static final String DATABASE_USERNAME = "root";
private static final String DATABASE_PASSWORD = "password";
private ConnectionSource connectionSource;
public ConnectionSource getConnectionSource() {
if (connectionSource == null) {
try {
connectionSource = new JdbcConnectionSource(DATABASE_URL, DATABASE_USERNAME, DATABASE_PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
}
return connectionSource;
}
}
import com.j256.ormlite.field.DatabaseField;
import com.j256.ormlite.table.DatabaseTable;
@DatabaseTable(tableName = "users")
public class User {
@DatabaseField(generatedId = true)
private int id;
@DatabaseField(canBeNull = false)
private String name;
@DatabaseField(canBeNull = false)
private int age;
}
import com.j256.ormlite.dao.Dao;
import com.j256.ormlite.dao.DaoManager;
import com.j256.ormlite.dao.GenericRawResults;
import com.j256.ormlite.stmt.DeleteBuilder;
import com.j256.ormlite.stmt.PreparedQuery;
import com.j256.ormlite.stmt.QueryBuilder;
import java.sql.SQLException;
import java.util.List;
public class Main {
public static void main(String[] args) {
try {
ConnectionSource connectionSource = new DatabaseConfig().getConnectionSource();
Dao<User, Integer> userDao = DaoManager.createDao(connectionSource, User.class);
userDao.create(user1);
List<User> users = userDao.queryForAll();
for (User user : users) {
}
QueryBuilder<User, Integer> queryBuilder = userDao.queryBuilder();
queryBuilder.where().ge("age", 18);
PreparedQuery<User> preparedQuery = queryBuilder.prepare();
List<User> adultUsers = userDao.query(preparedQuery);
for (User user : adultUsers) {
}
User userToUpdate = userDao.queryForId(1);
userDao.update(userToUpdate);
DeleteBuilder<User, Integer> deleteBuilder = userDao.deleteBuilder();
userDao.delete(deleteBuilder.prepare());
connectionSource.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
