MYSQL 怎么读取 SQL

mysql读取sql文件

mysql

-u用户名

-p密码

database名

<

aa.sql

但是初学建议还是一条条的执行,那样可以学到每句的意思

你应该说的MySQL的binlog（二进制日志）吧，她记录的内容是：任何引起或可能引起数据库变化的 *** 作 。

查询方式 ：

#查询某一段时间内的日志 start-datetime（开始时间）stop-datetime（结束时间） #mysql-bin.000001日志名称

mysqlbinlog mysql-bin.000001 \

--start-datetime="2015-10-05 17:34:40" \

--stop-datetime="2015-10-05 17:34:56" >sixteensecs.sql

#查看指定位置的日志 ，start-position（开始位置） stop-position（结束位置）

mysqlbinlog --read-from-remote-server -uuser -p \

mysql-bin.000001 -h 192.168.0.182 -P 3306 \

--start-position=932 --stop-position=1132 >remote000001.sql

打开日志内容，可以看到之前 *** 作的SQL脚本（语句：增加，修改，删除）

或者 开启 general_log 日志，打印所有 *** 作SQL脚本（语句），比较消耗性能，线上环境不建议开启，只是线上有问题时临时打开测试，测试完成后再关闭 。

读取数据库，首先要将数据库的驱动包导入：如果是mysql数据库，需要导入mysql-connector-java-5.1.27.jar，如果是oracle就需要导入oracle.jar包；

然后就是建立数据库连接，使用Connection 新建连接，然后执行你的sql语句查询出需要的数据，下面是两个方法： public PageModel findAllUser(int pageNo,int pageSize){String sql = "select * from user where user_name <>'root' order by user_name" +"limit" + (pageNo - 1) * pageSize + "," + pageSizePageModel pageModel =nullConnection conn =nullStatement stmt =nullResultSet rs = nulltry{conn = DB.getConn()stmt = conn.createStatement()rs = stmt.executeQuery(sql)List user_List = new ArrayList()while(rs.next()){User user = new User()user.setUser_name(rs.getString("user_name"))user.setUser_password(rs.getString("user_password"))user.setUser_tel(rs.getString("user_tel"))user.setUser_email(rs.getString("user_email"))user.setUser_createDate(rs.getTimestamp("user_createdate"))user_List.add(user)}//取得所有记录int totalRecords = getTotalRecords(conn)pageModel = new PageModel()pageModel.setPageSize(pageSize)pageModel.setList(user_List)pageModel.setTotalRecord(totalRecords)}catch(SQLException e){e.printStackTrace()}finally{DB.close(rs)DB.close(stmt)DB.close(conn)}return pageModel} /** * 取得所有记录 * @param conn * @return 所有记录totalRecords */public int getTotalRecords(Connection conn){String sql = "select count(*) from user where user_name <>'root' "int totalRecords = 0Statement stmt = nullResultSet rs = nulltry{conn = DB.getConn()stmt = conn.createStatement()rs = stmt.executeQuery(sql)if(rs.next()){totalRecords = rs.getInt(1)}}catch(SQLException e){e.printStackTrace()}finally{DB.close(rs)DB.close(stmt)DB.close(conn)}return totalRecords}

---