手写 Hibernate ORM 框架-04-数据库交互，数据持久化

目录

• 目录
• 本节内容
• 执行建表语句
  • Session
  • 测试
• 数据的持久化
  • 测试构建
  • 测试入库
• 目录导航

本节内容

执行建表语句。

执行数据的保存

执行建表语句

Session

package ;

import ;
import ;
import ;
import ;
import ;

import ;
import ;

/**
 * Session 实现
 * @author houbinbin
 * @date 16/6/5
 */
public class Session {

    /**
     * 获取数据库链接信息
     * @return
     */
    public Connection createConnection() {
        return ();
    }
}

测试

我们一开始写的数据库 Table 只是生成了脚本，但是没有实际执行。

有了 Connection 之后，我们就可以开始执行脚本啦。

/**
 * 执行建表语句
 * @throws SQLException SQL 异常
 */
@Test
public void executeCreateTableTest() throws SQLException {
    Session session = new Session();
    Table table = new Table();
    User user = new User();

    Connection connection = ();
    PreparedStatement preparedStatement = ((user));
    ();
}

数据的持久化

package ;

import ;
import ;
import ;
import ;
import ;

import ;
import ;

/**
 * Session 实现
 * @author houbinbin
 * @date 16/6/5
 */
public class Session {
    /**
     * 插入模板
     */
    private static final String INSERT_FORMAT = "INSERT INTO %s ( %s ) VALUES ( %s ) ;";

    /**
     * 保存用户信息
     * @param user
     * @throws SQLException
     */
    public void save(User user) throws SQLException {
        String sql = buildInsertSQL(user);

        Connection con = createConnection();
        PreparedStatement state =  (PreparedStatement) (sql);
        ();
        ();
    }

    /**
     * 构建插入语句
     * @param user
     * @return
     */
    public String buildInsertSQL(User user) {
        String tableName = (user);
        String fieldString = (user);
        String valueString = (user);

        return (INSERT_FORMAT, tableName, fieldString, valueString);
    }

    /**
     * 获取数据库链接信息
     * @return
     */
    public Connection createConnection() {
        return ();
    }
}

测试构建

@Test
public void buildInsertSQLTest() {
    User user = new User();
    (3L);
    ("ryo");
    (21);
    ("123456");
    (new Date());
    (new Date());
    (new Session().buildInsertSQL(user));
}

结果：

INSERT INTO t_user ( id,name,password,myAge,createOn,modifiedOn ) VALUES ( '3','ryo','123456','21','2018-05-02 22:33:32','2018-05-02 22:33:32' ) ;

测试入库

• insertUserTest()

@Test
public void insertUserTest() throws SQLException {
    User user = new User();
    (3L);
    ("ryo");
    (21);
    ("123456");
    (new Date());
    (new Date());

    new Session().save(user);
}

目录导航

目录导航