@ -77,6 +77,36 @@ public class CacheExporter @Inject constructor(
public val diskStoreValid : Boolean = blocks <= DiskStore . MAX _BLOCK
}
public data class Index (
val resolved : Boolean ,
val stats : IndexStats ?
)
public data class IndexStats (
val validGroups : Long ,
val groups : Long ,
val validKeys : Long ,
val keys : Long ,
val size : Long ,
val blocks : Long
) {
public val allGroupsValid : Boolean = groups == validGroups
public val validGroupsFraction : Double = if ( groups == 0L ) {
1.0
} else {
validGroups . toDouble ( ) / groups
}
public val allKeysValid : Boolean = keys == validKeys
public val validKeysFraction : Double = if ( keys == 0L ) {
1.0
} else {
validKeys . toDouble ( ) / keys
}
}
public data class Build ( val major : Int , val minor : Int ? ) : Comparable < Build > {
override fun compareTo ( other : Build ) : Int {
return compareValuesBy ( this , other , Build :: major , Build :: minor )
@ -128,6 +158,7 @@ public class CacheExporter @Inject constructor(
val sources : List < Source > ,
val updates : List < String > ,
val stats : Stats ? ,
val indexes : List < Index > ,
val masterIndex : Js5MasterIndex ? ,
val checksumTable : ChecksumTable ?
)
@ -379,7 +410,43 @@ public class CacheExporter @Inject constructor(
}
}
Cache ( id , sources , updates , stats , masterIndex , checksumTable )
val indexes = mutableListOf < Index > ( )
connection . prepareStatement (
"""
SELECT c . id IS NOT NULL , s . valid _groups , s . groups , s . valid _keys , s . keys , s . size , s . blocks
FROM master _index _archives a
LEFT JOIN resolve _index ( ( SELECT id FROM scopes WHERE name = ? ) , a . archive _id , a . crc32 , a . version ) c ON TRUE
LEFT JOIN index _stats s ON s . container _id = c . id
WHERE a . master _index _id = ?
ORDER BY a . archive _id ASC
""" .trimIndent()
) . use { stmt ->
stmt . setString ( 1 , scope )
stmt . setInt ( 2 , id )
stmt . executeQuery ( ) . use { rows ->
while ( rows . next ( ) ) {
val resolved = rows . getBoolean ( 1 )
val validGroups = rows . getLong ( 2 )
val indexStats = if ( ! rows . wasNull ( ) ) {
val groups = rows . getLong ( 3 )
val validKeys = rows . getLong ( 4 )
val keys = rows . getLong ( 5 )
val size = rows . getLong ( 6 )
val blocks = rows . getLong ( 7 )
IndexStats ( validGroups , groups , validKeys , keys , size , blocks )
} else {
null
}
indexes += Index ( resolved , indexStats )
}
}
}
Cache ( id , sources , updates , stats , indexes , masterIndex , checksumTable )
}
}
@ -446,7 +513,8 @@ public class CacheExporter @Inject constructor(
public suspend fun exportGroup ( scope : String , id : Int , archive : Int , group : Int ) : ByteBuf ? {
return database . execute { connection ->
connection . prepareStatement ( """
connection . prepareStatement (
"""
SELECT g . data
FROM resolved _groups g
JOIN scopes s ON s . id = g . scope _id
@ -455,7 +523,8 @@ public class CacheExporter @Inject constructor(
SELECT f . data
FROM resolved _files f
WHERE f . crc _table _id = ? AND f . index _id = ? AND f . file _id = ?
""" .trimIndent()).use { stmt ->
""" .trimIndent()
) . use { stmt ->
stmt . setString ( 1 , scope )
stmt . setInt ( 2 , id )
stmt . setInt ( 3 , archive )
Graham