分享下数据库的11种java写入方法
虽然自己不会写
但是我会复制粘贴
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ColumnListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
public class QueryRunnerDome {
public static Connection con = JDBCgongju.getConnection();
public static void main(String[] args) throws Exception {
insert();update();delete();arrayHandler();arrayListHandler();beanHandler();beanListHandler();
columnListHandler(); scalarHandler();mapHandler();mapListHandler();
}
public static void mapListHandler() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "SELECT*FROM sqlyog";
List<Map<String, Object>> list = qr.query(con, sql, new MapListHandler());
for (Map<String, Object> map : list) {
for (String key : map.keySet()) {
System.out.println(key + "..." + map.keySet());
}
}
}
public static void mapHandler() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "SELECT*FROM sqlyog";
Map<String, Object> map = qr.query(con, sql, new MapHandler());
for (String key : map.keySet()) {
System.out.println(key + "..." + map.get(key));
}
}
public static void scalarHandler() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "SELECT COUNT(*) FROM sqlyog";
long count = qr.query(con, sql, new ScalarHandler<Long>());
System.out.println(count);
}
public static void columnListHandler() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "SELECT *FROM sqlyog";
List<Object> list = qr.query(con, sql, new ColumnListHandler<Object>("name"));
for (Object obj : list) {
System.out.println(obj);
}
}
public static void beanListHandler() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "SELECT *FROM sqlyog";
List<Sqlyog> list = qr.query(con, sql, new BeanListHandler<Sqlyog>(Sqlyog.class));
for (Sqlyog s : list) {
System.out.println(s);
}
}
public static void beanHandler() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "SELECT *FROM sqlyog";
Sqlyog s = qr.query(con, sql, new BeanHandler<Sqlyog>(Sqlyog.class));
System.out.println(s);
}
public static void arrayListHandler() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "SELECT*FROM sqlyog ";
List<Object[]> result = qr.query(con, sql, new ArrayListHandler());
for (Object[] obj : result) {
for (Object objs : obj) {
System.out.println(objs);
}
}
}
public static void arrayHandler() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "SELECT*FROM sqlyog ";
Object[] result = qr.query(con, sql, new ArrayHandler());
for (Object obj : result) {
System.out.println(obj);
}
}
public static void delete() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "DELETE FROM sqlyog WHERE id=?";
int row = qr.update(con, sql, 8);// ID为8的删除
DbUtils.closeQuietly(con);
}
public static void update() throws Exception {
QueryRunner qr = new QueryRunner();
String sql = "UPDATE sqlyog SET name=?,sex=?,department=?, score=?WHERE id=? ";
Object[] params = { "嗯", "嗯", "嗯哼", 007, 3 };
int row = qr.update(con, sql, params);
DbUtils.closeQuietly(con);
}
public static void insert() throws SQLException {
QueryRunner qr = new QueryRunner();
String sql = "INSERT INTO sqlyog(name,sex,department,score) VALUES(?,?,?,?)";
Object[] params = { "嗯", "嗯", "嗯哼", 007 };
int row = qr.update(con, sql, params);// 调用QueryRunner方法的update执行SQL语句
System.out.println(row);
DbUtils.closeQuietly(con);
}
}
|
|