A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

© emmm... 中级黑马   /  2017-12-31 16:56  /  1334 人查看  /  3 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

分享下数据库的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);
        }
}


3 个回复

倒序浏览

新年快乐~~~~·
回复 使用道具 举报
新年快乐~~~~·
回复 使用道具 举报
温故而知新   加油哦   多多总结
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马