框架本身提供一个DBInputFormat。支持MySql和PostgreSQL(需要自己提供驱动jar包)。需要使用其他数据库可以自己实现相应的InputFormat;实现起来也不难参照DBInputFormat即可。只要将拼接的sql语句改成适用的语法即可。