import com.enklib.bigdata.db.DbConfig;
import com.enklib.bigdata.db.DbEnvironment;
DbConfig dbConfig = new DbConfig();
dbConfig.setDriver("com.mysql.jdbc.Driver");
dbConfig.setUrl("jdbc:mysql://localhost:3306/mydb");
dbConfig.setUsername("username");
dbConfig.setPassword("password");
DbEnvironment.init(dbConfig);
import com.enklib.bigdata.db.annotation.Column;
import com.enklib.bigdata.db.annotation.Table;
import com.enklib.bigdata.db.orm.BaseEntity;
@Table(name = "user")
public class User extends BaseEntity {
@Column(name = "id")
private Integer id;
@Column(name = "name")
private String name;
// getters and setters
}
import com.enklib.bigdata.db.Db;
import com.enklib.bigdata.db.DbSession;
import com.enklib.bigdata.db.QueryResult;
DbSession session = Db.openSession();
QueryResult<User> result = session.createQuery("SELECT * FROM user WHERE id = ?")
.setParameter(1, 1)
.list(User.class);
List<User> userList = result.getRows();
User newUser = new User();
newUser.setId(2);
newUser.setName("John");
session.insert(newUser);
session.close();
