本文整理了Java中java.sql.ResultSet.getTimestamp
方法的一些代码示例,展示了ResultSet.getTimestamp
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ResultSet.getTimestamp
方法的具体详情如下:
包路径:java.sql.ResultSet
类名称:ResultSet
方法名:getTimestamp
[英]Gets the value of a column specified by column index as a java.sql.Timestamp value.
[中]获取列索引指定为java的列的值。sql。时间戳值。
代码示例来源:origin: nutzam/nutz
public Object invoke(Connection conn, ResultSet rs, Sql sql) throws SQLException {
if (null != rs && rs.next())
return rs.getTimestamp(1);
return null;
}
代码示例来源:origin: dropwizard/dropwizard
@Override
@Nullable
public DateTime mapColumn(ResultSet r, int columnNumber, StatementContext ctx) throws SQLException {
final Timestamp timestamp = calendar.isPresent() ? r.getTimestamp(columnNumber, cloneCalendar()) :
r.getTimestamp(columnNumber);
if (timestamp == null) {
return null;
}
return new DateTime(timestamp.getTime());
}
代码示例来源:origin: spring-projects/spring-security-oauth
@Override
public Approval mapRow(ResultSet rs, int rowNum) throws SQLException {
String userName = rs.getString(4);
String clientId = rs.getString(5);
String scope = rs.getString(6);
Date expiresAt = rs.getTimestamp(1);
String status = rs.getString(2);
Date lastUpdatedAt = rs.getTimestamp(3);
return new Approval(userName, clientId, scope, expiresAt, ApprovalStatus.valueOf(status), lastUpdatedAt);
}
}
代码示例来源:origin: qunarcorp/qmq
private static MsgQueue toMsgQueue(ResultSet rs, int rowNum) throws SQLException {
return new MsgQueue(
rs.getLong("id"),
rs.getString("content"),
rs.getInt("error"),
rs.getTimestamp("update_time"));
}
代码示例来源:origin: elasticjob/elastic-job-lite
/**
* 获取最近一条运行中的任务统计数据.
*
* @return 运行中的任务统计数据对象
*/
public Optional<TaskRunningStatistics> findLatestTaskRunningStatistics() {
TaskRunningStatistics result = null;
String sql = String.format("SELECT id, running_count, statistics_time, creation_time FROM %s order by id DESC LIMIT 1",
TABLE_TASK_RUNNING_STATISTICS);
try (
Connection conn = dataSource.getConnection();
PreparedStatement preparedStatement = conn.prepareStatement(sql);
ResultSet resultSet = preparedStatement.executeQuery()
) {
while (resultSet.next()) {
result = new TaskRunningStatistics(resultSet.getLong(1), resultSet.getInt(2),
new Date(resultSet.getTimestamp(3).getTime()), new Date(resultSet.getTimestamp(4).getTime()));
}
} catch (final SQLException ex) {
// TODO 记录失败直接输出日志,未来可考虑配置化
log.error("Fetch latest taskRunningStatistics from DB error:", ex);
}
return Optional.fromNullable(result);
}
代码示例来源:origin: cloudfoundry/uaa
@Override
public ScimGroup mapRow(ResultSet rs, int rowNum) throws SQLException {
int pos = 1;
String id = rs.getString(pos++);
String name = rs.getString(pos++);
String description = rs.getString(pos++);
Date created = rs.getTimestamp(pos++);
Date modified = rs.getTimestamp(pos++);
int version = rs.getInt(pos++);
String zoneId = rs.getString(pos++);
ScimGroup group = new ScimGroup(id, name, zoneId);
group.setDescription(description);
ScimMeta meta = new ScimMeta(created, modified, version);
group.setMeta(meta);
return group;
}
代码示例来源:origin: syncany/syncany
try (ResultSet resultSet = preparedStatement.executeQuery()) {
DatabaseVersionHeader currentDatabaseVersionHeader = null;
int currentDatabaseVersionHeaderId = -1;
while (resultSet.next()) {
int databaseVersionHeaderId = resultSet.getInt("id");
currentDatabaseVersionHeader.setClient(resultSet.getString("client"));
currentDatabaseVersionHeader.setDate(new Date(resultSet.getTimestamp("localtime").getTime()));
currentDatabaseVersionHeader.getVectorClock().setClock(resultSet.getString("vc_client"), resultSet.getLong("vc_logicaltime"));
代码示例来源:origin: com.h2database/h2
writeRow(row);
while (rs.next()) {
for (int i = 0; i < columnCount; i++) {
Object o;
break;
case Types.TIMESTAMP:
o = rs.getTimestamp(i + 1);
break;
default:
o = rs.getString(i + 1);
代码示例来源:origin: cloudfoundry/uaa
@Override
public TokenCode mapRow(ResultSet rs, int rowNum) throws SQLException {
int pos = 1;
String code = rs.getString(pos++);
String userid = rs.getString(pos++);
String client_id = rs.getString(pos++);
long expiresat = rs.getLong(pos++);
Timestamp created = rs.getTimestamp(pos++);
byte[] authentication = rs.getBytes(pos++);
return createTokenCode(code, userid, client_id, expiresat, created, authentication);
}
}
代码示例来源:origin: apache/ignite
/**
* @throws Exception If failed.
*/
@Test
public void testTimestamp() throws Exception {
ResultSet rs = stmt.executeQuery(SQL);
int cnt = 0;
while (rs.next()) {
if (cnt == 0) {
assert rs.getTimestamp("tsVal").getTime() == 1;
assert rs.getTimestamp(14).getTime() == 1;
}
cnt++;
}
assert cnt == 1;
}
代码示例来源:origin: speedment/speedment
protected Rental apply(ResultSet resultSet, int offset) throws SQLException {
return createEntity()
.setRentalId( resultSet.getInt(1 + offset))
.setRentalDate( resultSet.getTimestamp(2 + offset))
.setInventoryId( resultSet.getInt(3 + offset))
.setCustomerId( resultSet.getInt(4 + offset))
.setReturnDate( resultSet.getTimestamp(5 + offset))
.setStaffId( resultSet.getShort(6 + offset))
.setLastUpdate( resultSet.getTimestamp(7 + offset))
;
}
代码示例来源:origin: apache/phoenix
@Test
public void testInsertingRetrivingTimestamp() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
String t = generateUniqueName();
String ddl = "CREATE TABLE " + t + " (K INTEGER NOT NULL PRIMARY KEY, V TIMESTAMP)";
conn.createStatement().execute(ddl);
String dml = "UPSERT INTO " + t + " VALUES (?, ?)";
PreparedStatement stmt = conn.prepareStatement(dml);
stmt.setInt(1, 1);
Calendar cal = Calendar.getInstance();
cal.setTimeZone(TimeZone.getTimeZone("US/Hawaii"));
long time = System.currentTimeMillis();
stmt.setTimestamp(2, new Timestamp(time), cal);
stmt.executeUpdate();
conn.commit();
String query = "SELECT V FROM " + t;
ResultSet rs = conn.createStatement().executeQuery(query);
rs.next();
assertEquals(new Timestamp(time), rs.getTimestamp(1));
assertEquals(new Timestamp(time), rs.getTimestamp("V"));
assertEquals(new Timestamp(time), rs.getTimestamp(1, cal));
assertEquals(new Timestamp(time), rs.getTimestamp("V", cal));
}
代码示例来源:origin: alibaba/nacos
public ConfigAdvanceInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
ConfigAdvanceInfo info = new ConfigAdvanceInfo();
info.setCreateTime(rs.getTimestamp("gmt_modified").getTime());
info.setModifyTime(rs.getTimestamp("gmt_modified").getTime());
info.setCreateUser(rs.getString("src_user"));
info.setCreateIp(rs.getString("src_ip"));
info.setDesc(rs.getString("c_desc"));
info.setUse(rs.getString("c_use"));
info.setEffect(rs.getString("effect"));
info.setType(rs.getString("type"));
info.setSchema(rs.getString("c_schema"));
return info;
}
}
代码示例来源:origin: elasticjob/elastic-job-lite
private List<JobExecutionEvent> getJobExecutionEvents(final Condition condition) {
List<JobExecutionEvent> result = new LinkedList<>();
try (
Connection conn = dataSource.getConnection();
PreparedStatement preparedStatement = createDataPreparedStatement(conn, TABLE_JOB_EXECUTION_LOG, FIELDS_JOB_EXECUTION_LOG, condition);
ResultSet resultSet = preparedStatement.executeQuery()
) {
while (resultSet.next()) {
JobExecutionEvent jobExecutionEvent = new JobExecutionEvent(resultSet.getString(1), resultSet.getString(2), resultSet.getString(3), resultSet.getString(4),
resultSet.getString(5), JobExecutionEvent.ExecutionSource.valueOf(resultSet.getString(6)), Integer.valueOf(resultSet.getString(7)),
new Date(resultSet.getTimestamp(8).getTime()), resultSet.getTimestamp(9) == null ? null : new Date(resultSet.getTimestamp(9).getTime()),
resultSet.getBoolean(10), new JobExecutionEventThrowable(null, resultSet.getString(11))
);
result.add(jobExecutionEvent);
}
} catch (final SQLException ex) {
// TODO 记录失败直接输出日志,未来可考虑配置化
log.error("Fetch JobExecutionEvent from DB error:", ex);
}
return result;
}
代码示例来源:origin: elasticjob/elastic-job-lite
/**
* 获取最近一条运行中的任务统计数据.
*
* @return 运行中的任务统计数据对象
*/
public Optional<JobRunningStatistics> findLatestJobRunningStatistics() {
JobRunningStatistics result = null;
String sql = String.format("SELECT id, running_count, statistics_time, creation_time FROM %s order by id DESC LIMIT 1",
TABLE_JOB_RUNNING_STATISTICS);
try (
Connection conn = dataSource.getConnection();
PreparedStatement preparedStatement = conn.prepareStatement(sql);
ResultSet resultSet = preparedStatement.executeQuery()
) {
while (resultSet.next()) {
result = new JobRunningStatistics(resultSet.getLong(1), resultSet.getInt(2),
new Date(resultSet.getTimestamp(3).getTime()), new Date(resultSet.getTimestamp(4).getTime()));
}
} catch (final SQLException ex) {
// TODO 记录失败直接输出日志,未来可考虑配置化
log.error("Fetch latest jobRunningStatistics from DB error:", ex);
}
return Optional.fromNullable(result);
}
代码示例来源:origin: speedment/speedment
protected Country apply(ResultSet resultSet, int offset) throws SQLException {
return createEntity()
.setCountryId( resultSet.getInt(1 + offset))
.setCountry( resultSet.getString(2 + offset))
.setLastUpdate( resultSet.getTimestamp(3 + offset))
;
}
代码示例来源:origin: prestodb/presto
@Test
public void testSetTimeZoneId()
throws Exception
{
TimeZoneKey defaultZoneKey = TimeZoneKey.getTimeZoneKey(TimeZone.getDefault().getID());
DateTimeZone defaultZone = DateTimeZone.forTimeZone(TimeZone.getDefault());
String sql = "SELECT current_timezone() zone, TIMESTAMP '2001-02-03 3:04:05' ts";
try (Connection connection = createConnection()) {
try (Statement statement = connection.createStatement();
ResultSet rs = statement.executeQuery(sql)) {
assertTrue(rs.next());
assertEquals(rs.getString("zone"), defaultZoneKey.getId());
assertEquals(rs.getTimestamp("ts"), new Timestamp(new DateTime(2001, 2, 3, 3, 4, 5, defaultZone).getMillis()));
}
connection.unwrap(PrestoConnection.class).setTimeZoneId("UTC");
try (Statement statement = connection.createStatement();
ResultSet rs = statement.executeQuery(sql)) {
assertTrue(rs.next());
assertEquals(rs.getString("zone"), "UTC");
assertEquals(rs.getTimestamp("ts"), new Timestamp(new DateTime(2001, 2, 3, 3, 4, 5, DateTimeZone.UTC).getMillis()));
}
}
}
代码示例来源:origin: alibaba/druid
private MonitorInstance readInst(ResultSet rs) throws SQLException {
MonitorInstance inst = new MonitorInstance();
inst.setId(rs.getLong(1));
inst.setDomain(rs.getString(2));
inst.setApp(rs.getString(3));
inst.setCluster(rs.getString(4));
inst.setHost(rs.getString(5));
inst.setIp(rs.getString(6));
inst.setLastActiveTime(rs.getTimestamp(7));
inst.setLastPID(rs.getLong(8));
return inst;
}
}
代码示例来源:origin: apache/ignite
/**
* @throws Exception If failed.
*/
@Test
public void testTimestamp() throws Exception {
ResultSet rs = stmt.executeQuery(SQL);
int cnt = 0;
while (rs.next()) {
if (cnt == 0) {
assert rs.getTimestamp("tsVal").getTime() == 1;
assert rs.getDate(14).equals(new Date(new Timestamp(1).getTime()));
assert rs.getTime(14).equals(new Time(new Timestamp(1).getTime()));
assert rs.getTimestamp(14).equals(new Timestamp(1));
assert rs.getObject(14, Date.class).equals(new Date(new Timestamp(1).getTime()));
assert rs.getObject(14, Time.class).equals(new Time(new Timestamp(1).getTime()));
assert rs.getObject(14, Timestamp.class).equals(new Timestamp(1));
}
cnt++;
}
assert cnt == 1;
}
代码示例来源:origin: speedment/speedment
protected FilmActor apply(ResultSet resultSet, int offset) throws SQLException {
return createEntity()
.setActorId( resultSet.getInt(1 + offset))
.setFilmId( resultSet.getInt(2 + offset))
.setLastUpdate( resultSet.getTimestamp(3 + offset))
;
}
内容来源于网络,如有侵权,请联系作者删除!