diff --git a/zcash_client_backend/src/data_api/chain.rs b/zcash_client_backend/src/data_api/chain.rs
index 1555785f85..143e45ca97 100644
--- a/zcash_client_backend/src/data_api/chain.rs
+++ b/zcash_client_backend/src/data_api/chain.rs
@@ -161,6 +161,8 @@ use crate::{
 pub mod error;
 use error::Error;
 
+use super::WalletRead;
+
 /// A struct containing metadata about a subtree root of the note commitment tree.
 ///
 /// This stores the block height at which the leaf that completed the subtree was
@@ -277,6 +279,7 @@ where
     ParamsT: consensus::Parameters + Send + 'static,
     BlockSourceT: BlockSource,
     DbT: WalletWrite,
+    <DbT as WalletRead>::AccountPK: 'static,
 {
     // Fetch the UnifiedFullViewingKeys we are tracking
     let ufvks = data_db
diff --git a/zcash_client_backend/src/scanning.rs b/zcash_client_backend/src/scanning.rs
index 6e521165d1..f3eb61a178 100644
--- a/zcash_client_backend/src/scanning.rs
+++ b/zcash_client_backend/src/scanning.rs
@@ -255,7 +255,7 @@ pub fn scan_block<P: consensus::Parameters + Send + 'static, K: ScanningKey, Acc
     prior_block_metadata: Option<&BlockMetadata>,
 ) -> Result<ScannedBlock<K::Nf, K::Scope, AccountPK>, ScanError>
 where
-    AccountPK: Copy + Clone + Send + PartialEq + Eq + std::hash::Hash,
+    AccountPK: Copy + Clone + Send + PartialEq + Eq + std::hash::Hash + 'static,
 {
     scan_block_with_runner::<_, _, (), AccountPK>(
         params,
@@ -268,10 +268,14 @@ where
 }
 
 type TaggedBatch<S, AccountPK> =
-   
     Batch<(AccountId<AccountPK>, S), SaplingDomain, CompactOutputDescription, CompactDecryptor>;
-type TaggedBatchRunner<S, T, AccountPK> =
-    BatchRunner<(AccountId<AccountPK>, S), SaplingDomain, CompactOutputDescription, CompactDecryptor, T>;
+type TaggedBatchRunner<S, T, AccountPK> = BatchRunner<
+    (AccountId<AccountPK>, S),
+    SaplingDomain,
+    CompactOutputDescription,
+    CompactDecryptor,
+    T,
+>;
 
 #[tracing::instrument(skip_all, fields(height = block.height))]
 pub(crate) fn add_block_to_runner<P, S, T, AccountPK>(
@@ -282,7 +286,7 @@ pub(crate) fn add_block_to_runner<P, S, T, AccountPK>(
     P: consensus::Parameters + Send + 'static,
     S: Clone + Send + 'static,
     T: Tasks<TaggedBatch<S, AccountPK>>,
-    AccountPK: Copy + Clone + Send + PartialEq + Eq + std::hash::Hash,
+    AccountPK: Copy + Clone + Send + PartialEq + Eq + std::hash::Hash + 'static,
 {
     let block_hash = block.hash();
     let block_height = block.height();
@@ -345,7 +349,7 @@ pub(crate) fn scan_block_with_runner<
     mut batch_runner: Option<&mut TaggedBatchRunner<K::Scope, T, AccountPK>>,
 ) -> Result<ScannedBlock<K::Nf, K::Scope, AccountPK>, ScanError>
 where
-    AccountPK: std::cmp::Eq + std::hash::Hash + Clone + Send + Copy,
+    AccountPK: std::cmp::Eq + std::hash::Hash + Clone + Send + Copy + 'static,
 {
     if let Some(scan_error) = check_hash_continuity(&block, prior_block_metadata) {
         return Err(scan_error);
diff --git a/zcash_client_sqlite/src/error.rs b/zcash_client_sqlite/src/error.rs
index b28a139645..70f1fa32fb 100644
--- a/zcash_client_sqlite/src/error.rs
+++ b/zcash_client_sqlite/src/error.rs
@@ -4,6 +4,8 @@ use std::error;
 use std::fmt;
 
 use shardtree::error::ShardTreeError;
+use zcash_client_backend::data_api::AccountParameters;
+use zcash_client_backend::data_api::HDSeedAccount;
 use zcash_client_backend::{
     data_api::AccountId,
     encoding::{Bech32DecodeError, TransparentCodecError},
@@ -71,11 +73,11 @@ pub enum SqliteClientError {
     DiversifierIndexOutOfRange,
 
     /// The account for which information was requested does not belong to the wallet.
-    AccountUnknown(AccountId),
+    AccountUnknown(AccountParameters), // TODO: AccountId<AccountPK> would probably be a bit better here, but would make the error type generic
 
     /// An error occurred deriving a spending key from a seed and an account
     /// identifier.
-    KeyDerivationError(AccountId), // Is there a way to constrain this to AccountId::Zip32?
+    KeyDerivationError(HDSeedAccount),
 
     /// A caller attempted to initialize the accounts table with a discontinuous
     /// set of account identifiers.
diff --git a/zcash_client_sqlite/src/lib.rs b/zcash_client_sqlite/src/lib.rs
index 241bac52f6..cbba65681a 100644
--- a/zcash_client_sqlite/src/lib.rs
+++ b/zcash_client_sqlite/src/lib.rs
@@ -184,14 +184,15 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> InputSource for
         wallet::sapling::get_spendable_sapling_note(self.conn.borrow(), &self.params, txid, index)
     }
 
-    fn select_spendable_notes(
+    fn select_spendable_notes<AccountPK>(
         &self,
-        account: AccountId,
+        account: AccountId<AccountPK>,
         target_value: Amount,
         _sources: &[ShieldedProtocol],
         anchor_height: BlockHeight,
         exclude: &[Self::NoteRef],
-    ) -> Result<Vec<ReceivedNote<Self::NoteRef, Note>>, Self::Error> {
+    ) -> Result<Vec<ReceivedNote<Self::NoteRef, Note>>, Self::Error> 
+    where AccountPK : Copy + Clone + Send + PartialEq + Eq + std::hash::Hash{
         wallet::sapling::select_spendable_sapling_notes(
             self.conn.borrow(),
             &self.params,
@@ -282,13 +283,16 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
         wallet::wallet_birthday(self.conn.borrow()).map_err(SqliteClientError::from)
     }
 
-    fn get_account_birthday(&self, account: AccountId) -> Result<BlockHeight, Self::Error> {
+    fn get_account_birthday(
+        &self,
+        account: AccountId<Self::AccountPK>,
+    ) -> Result<BlockHeight, Self::Error> {
         wallet::account_birthday(self.conn.borrow(), account).map_err(SqliteClientError::from)
     }
 
     fn get_current_address(
         &self,
-        account: AccountId,
+        account: AccountId<Self::AccountPK>,
     ) -> Result<Option<UnifiedAddress>, Self::Error> {
         wallet::get_current_address(self.conn.borrow(), &self.params, account)
             .map(|res| res.map(|(addr, _)| addr))
@@ -296,21 +300,21 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
 
     fn get_unified_full_viewing_keys(
         &self,
-    ) -> Result<HashMap<AccountId, UnifiedFullViewingKey>, Self::Error> {
+    ) -> Result<HashMap<AccountId<Self::AccountPK>, UnifiedFullViewingKey>, Self::Error> {
         wallet::get_unified_full_viewing_keys(self.conn.borrow(), &self.params)
     }
 
     fn get_account_for_ufvk(
         &self,
         ufvk: &UnifiedFullViewingKey,
-    ) -> Result<Option<AccountId>, Self::Error> {
+    ) -> Result<Option<AccountId<Self::AccountPK>>, Self::Error> {
         wallet::get_account_for_ufvk(self.conn.borrow(), &self.params, ufvk)
     }
 
     fn get_wallet_summary(
         &self,
         min_confirmations: u32,
-    ) -> Result<Option<WalletSummary>, Self::Error> {
+    ) -> Result<Option<WalletSummary<Self::AccountPK>>, Self::Error> {
         // This will return a runtime error if we call `get_wallet_summary` from two
         // threads at the same time, as transactions cannot nest.
         wallet::get_wallet_summary(
@@ -337,7 +341,7 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
     fn get_sapling_nullifiers(
         &self,
         query: NullifierQuery,
-    ) -> Result<Vec<(AccountId, sapling::Nullifier)>, Self::Error> {
+    ) -> Result<Vec<(AccountId<Self::AccountPK>, sapling::Nullifier)>, Self::Error> {
         match query {
             NullifierQuery::Unspent => wallet::sapling::get_sapling_nullifiers(self.conn.borrow()),
             NullifierQuery::All => wallet::sapling::get_all_sapling_nullifiers(self.conn.borrow()),
@@ -346,7 +350,7 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
 
     fn get_transparent_receivers(
         &self,
-        _account: AccountId,
+        _account: AccountId<Self::AccountPK>,
     ) -> Result<HashMap<TransparentAddress, AddressMetadata>, Self::Error> {
         #[cfg(feature = "transparent-inputs")]
         return wallet::get_transparent_receivers(self.conn.borrow(), &self.params, _account);
@@ -359,7 +363,7 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
 
     fn get_transparent_balances(
         &self,
-        _account: AccountId,
+        _account: AccountId<Self::AccountPK>,
         _max_height: BlockHeight,
     ) -> Result<HashMap<TransparentAddress, Amount>, Self::Error> {
         #[cfg(feature = "transparent-inputs")]
@@ -380,11 +384,11 @@ impl<C: Borrow<rusqlite::Connection>, P: consensus::Parameters> WalletRead for W
     fn get_orchard_nullifiers(
         &self,
         _query: NullifierQuery,
-    ) -> Result<Vec<(AccountId, orchard::note::Nullifier)>, Self::Error> {
+    ) -> Result<Vec<(AccountId<Self::AccountPK>, orchard::note::Nullifier)>, Self::Error> {
         todo!()
     }
 
-    fn get_account_ids(&self) -> Result<Vec<AccountId>, Self::Error> {
+    fn get_account_ids(&self) -> Result<Vec<AccountId<Self::AccountPK>>, Self::Error> {
         wallet::get_account_ids(self.conn.borrow())
     }
 }
@@ -396,7 +400,7 @@ impl<P: consensus::Parameters> WalletWrite for WalletDb<rusqlite::Connection, P>
         &mut self,
         seed: &SecretVec<u8>,
         birthday: AccountBirthday,
-    ) -> Result<(AccountId, UnifiedSpendingKey), Self::Error> {
+    ) -> Result<(AccountId<Self::AccountPK>, UnifiedSpendingKey), Self::Error> {
         let seed_id = HDSeedFingerprint::from_seed(seed);
         self.transactionally(|wdb| {
             let account_id = wallet::get_max_account_id(wdb.conn.0, &seed_id)?
@@ -420,7 +424,7 @@ impl<P: consensus::Parameters> WalletWrite for WalletDb<rusqlite::Connection, P>
 
     fn get_next_available_address(
         &mut self,
-        account: AccountId,
+        account: AccountId<Self::AccountPK>,
         request: UnifiedAddressRequest,
     ) -> Result<Option<UnifiedAddress>, Self::Error> {
         self.transactionally(
@@ -460,7 +464,7 @@ impl<P: consensus::Parameters> WalletWrite for WalletDb<rusqlite::Connection, P>
     #[allow(clippy::type_complexity)]
     fn put_blocks(
         &mut self,
-        blocks: Vec<ScannedBlock<sapling::Nullifier, Scope>>,
+        blocks: Vec<ScannedBlock<sapling::Nullifier, Scope, Self::AccountPK>>,
     ) -> Result<(), Self::Error> {
         self.transactionally(|wdb| {
             let start_positions = blocks.first().map(|block| {
@@ -599,11 +603,14 @@ impl<P: consensus::Parameters> WalletWrite for WalletDb<rusqlite::Connection, P>
         Ok(())
     }
 
-    fn store_decrypted_tx(&mut self, d_tx: DecryptedTransaction) -> Result<(), Self::Error> {
+    fn store_decrypted_tx(
+        &mut self,
+        d_tx: DecryptedTransaction<Self::AccountPK>,
+    ) -> Result<(), Self::Error> {
         self.transactionally(|wdb| {
             let tx_ref = wallet::put_tx_data(wdb.conn.0, d_tx.tx, None, None)?;
 
-            let mut spending_account_id: Option<AccountId> = None;
+            let mut spending_account_id: Option<AccountId<Self::AccountPK>> = None;
             for output in d_tx.sapling_outputs {
                 match output.transfer_type {
                     TransferType::Outgoing | TransferType::WalletInternal => {
@@ -690,7 +697,10 @@ impl<P: consensus::Parameters> WalletWrite for WalletDb<rusqlite::Connection, P>
         })
     }
 
-    fn store_sent_tx(&mut self, sent_tx: &SentTransaction) -> Result<(), Self::Error> {
+    fn store_sent_tx(
+        &mut self,
+        sent_tx: &SentTransaction<Self::AccountPK>,
+    ) -> Result<(), Self::Error> {
         self.transactionally(|wdb| {
             let tx_ref = wallet::put_tx_data(
                 wdb.conn.0,
@@ -1132,7 +1142,7 @@ extern crate assert_matches;
 mod tests {
     use zcash_client_backend::data_api::{AccountBirthday, WalletRead, WalletWrite};
 
-    use crate::{testing::TestBuilder, AccountId, DEFAULT_UA_REQUEST};
+    use crate::{testing::TestBuilder, DEFAULT_UA_REQUEST};
 
     #[cfg(feature = "unstable")]
     use {
diff --git a/zcash_client_sqlite/src/testing.rs b/zcash_client_sqlite/src/testing.rs
index 31ca460d32..9485031406 100644
--- a/zcash_client_sqlite/src/testing.rs
+++ b/zcash_client_sqlite/src/testing.rs
@@ -91,6 +91,8 @@ pub(crate) struct TestBuilder<Cache> {
     test_account_birthday: Option<AccountBirthday>,
 }
 
+type AccountPK = ();
+
 impl TestBuilder<()> {
     /// Constructs a new test.
     pub(crate) fn new() -> Self {
@@ -160,7 +162,7 @@ pub(crate) struct TestState<Cache> {
     latest_cached_block: Option<(BlockHeight, BlockHash, u32)>,
     _data_file: NamedTempFile,
     db_data: WalletDb<Connection, Network>,
-    test_account: Option<(AccountId, UnifiedSpendingKey, AccountBirthday)>,
+    test_account: Option<(AccountId<AccountPK>, UnifiedSpendingKey, AccountBirthday)>,
 }
 
 impl<Cache: TestCache> TestState<Cache>
@@ -418,7 +420,7 @@ impl<Cache> TestState<Cache> {
     }
 
     /// Exposes the test account, if enabled via [`TestBuilder::with_test_account`].
-    pub(crate) fn test_account(&self) -> Option<(AccountId, UnifiedSpendingKey, AccountBirthday)> {
+    pub(crate) fn test_account(&self) -> Option<(AccountId<AccountPK>, UnifiedSpendingKey, AccountBirthday)> {
         self.test_account.as_ref().cloned()
     }
 
@@ -508,7 +510,7 @@ impl<Cache> TestState<Cache> {
     #[allow(clippy::type_complexity)]
     pub(crate) fn propose_transfer<InputsT>(
         &mut self,
-        spend_from_account: AccountId,
+        spend_from_account: AccountId<AccountPK>,
         input_selector: &InputsT,
         request: zip321::TransactionRequest,
         min_confirmations: NonZeroU32,
@@ -540,7 +542,7 @@ impl<Cache> TestState<Cache> {
     #[allow(clippy::too_many_arguments)]
     pub(crate) fn propose_standard_transfer<CommitmentTreeErrT>(
         &mut self,
-        spend_from_account: AccountId,
+        spend_from_account: AccountId<AccountPK>,
         fee_rule: StandardFeeRule,
         min_confirmations: NonZeroU32,
         to: &Address,
@@ -679,7 +681,7 @@ impl<Cache> TestState<Cache> {
 
     fn with_account_balance<T, F: FnOnce(&AccountBalance) -> T>(
         &self,
-        account: AccountId,
+        account: AccountId<AccountPK>,
         min_confirmations: u32,
         f: F,
     ) -> T {
@@ -687,13 +689,13 @@ impl<Cache> TestState<Cache> {
         f(binding.account_balances().get(&account).unwrap())
     }
 
-    pub(crate) fn get_total_balance(&self, account: AccountId) -> NonNegativeAmount {
+    pub(crate) fn get_total_balance(&self, account: AccountId<AccountPK>) -> NonNegativeAmount {
         self.with_account_balance(account, 0, |balance| balance.total())
     }
 
     pub(crate) fn get_spendable_balance(
         &self,
-        account: AccountId,
+        account: AccountId<AccountPK>,
         min_confirmations: u32,
     ) -> NonNegativeAmount {
         self.with_account_balance(account, min_confirmations, |balance| {
@@ -703,7 +705,7 @@ impl<Cache> TestState<Cache> {
 
     pub(crate) fn get_pending_shielded_balance(
         &self,
-        account: AccountId,
+        account: AccountId<AccountPK>,
         min_confirmations: u32,
     ) -> NonNegativeAmount {
         self.with_account_balance(account, min_confirmations, |balance| {
@@ -716,7 +718,7 @@ impl<Cache> TestState<Cache> {
     #[allow(dead_code)]
     pub(crate) fn get_pending_change(
         &self,
-        account: AccountId,
+        account: AccountId<AccountPK>,
         min_confirmations: u32,
     ) -> NonNegativeAmount {
         self.with_account_balance(account, min_confirmations, |balance| {
@@ -724,7 +726,7 @@ impl<Cache> TestState<Cache> {
         })
     }
 
-    pub(crate) fn get_wallet_summary(&self, min_confirmations: u32) -> Option<WalletSummary> {
+    pub(crate) fn get_wallet_summary(&self, min_confirmations: u32) -> Option<WalletSummary<AccountPK>> {
         get_wallet_summary(
             &self.wallet().conn.unchecked_transaction().unwrap(),
             &self.wallet().params,
diff --git a/zcash_client_sqlite/src/wallet.rs b/zcash_client_sqlite/src/wallet.rs
index 676fde6ac8..0d2f905479 100644
--- a/zcash_client_sqlite/src/wallet.rs
+++ b/zcash_client_sqlite/src/wallet.rs
@@ -90,7 +90,7 @@ use zcash_client_backend::{
     address::{Address, UnifiedAddress},
     data_api::{
         scanning::{ScanPriority, ScanRange},
-        AccountBirthday, AccountId, BlockMetadata, SentTransactionOutput, SAPLING_SHARD_HEIGHT,
+        AccountBirthday, BlockMetadata, SentTransactionOutput, SAPLING_SHARD_HEIGHT,
     },
     encoding::AddressCodec,
     keys::UnifiedFullViewingKey,
@@ -119,6 +119,9 @@ use {
     },
 };
 
+type AccountPK = u32;
+type AccountId = zcash_client_backend::data_api::AccountId<AccountPK>;
+
 pub mod commitment_tree;
 pub mod init;
 pub(crate) mod sapling;
@@ -178,7 +181,7 @@ pub(crate) fn get_max_account_id(
     })
 }
 
-pub(crate) fn add_account<P: consensus::Parameters>(
+pub(crate) fn add_account<P: consensus::Parameters, AccountPK>(
     conn: &rusqlite::Transaction,
     params: &P,
     account: AccountId,
@@ -583,7 +586,7 @@ pub(crate) fn get_wallet_summary<P: consensus::Parameters>(
     params: &P,
     min_confirmations: u32,
     progress: &impl ScanProgress,
-) -> Result<Option<WalletSummary>, SqliteClientError> {
+) -> Result<Option<WalletSummary<AccountPK>>, SqliteClientError> {
     let chain_tip_height = match scan_queue_extrema(tx)? {
         Some(range) => *range.end(),
         None => {
@@ -1589,7 +1592,7 @@ pub(crate) fn put_block(
 /// contain a note related to this wallet into the database.
 pub(crate) fn put_tx_meta<N, S>(
     conn: &rusqlite::Connection,
-    tx: &WalletTx<N, S>,
+    tx: &WalletTx<N, S, AccountPK>,
     height: BlockHeight,
 ) -> Result<i64, SqliteClientError> {
     // It isn't there, so insert our transaction into the database.
@@ -1776,7 +1779,7 @@ pub(crate) fn update_expired_notes(
 // and `put_sent_output`
 fn recipient_params<P: consensus::Parameters>(
     params: &P,
-    to: &Recipient,
+    to: &Recipient<AccountPK>,
 ) -> (Option<String>, Option<u32>, PoolType) {
     match to {
         Recipient::Transparent(addr) => (Some(addr.encode(params)), None, PoolType::Transparent),
@@ -1796,7 +1799,7 @@ pub(crate) fn insert_sent_output<P: consensus::Parameters>(
     params: &P,
     tx_ref: i64,
     from_account: AccountId,
-    output: &SentTransactionOutput,
+    output: &SentTransactionOutput<AccountPK>,
 ) -> Result<(), SqliteClientError> {
     let mut stmt_insert_sent_output = conn.prepare_cached(
         "INSERT INTO sent_notes (
@@ -1842,7 +1845,7 @@ pub(crate) fn put_sent_output<P: consensus::Parameters>(
     from_account: AccountId,
     tx_ref: i64,
     output_index: usize,
-    recipient: &Recipient,
+    recipient: &Recipient<AccountPK>,
     value: NonNegativeAmount,
     memo: Option<&MemoBytes>,
 ) -> Result<(), SqliteClientError> {
diff --git a/zcash_client_sqlite/src/wallet/init.rs b/zcash_client_sqlite/src/wallet/init.rs
index d605332552..33d0f7c635 100644
--- a/zcash_client_sqlite/src/wallet/init.rs
+++ b/zcash_client_sqlite/src/wallet/init.rs
@@ -18,6 +18,8 @@ use crate::WalletDb;
 
 use super::commitment_tree::{self};
 
+type AccountId = zcash_client_backend::data_api::AccountId<u32>;
+
 mod migrations;
 
 #[derive(Debug)]
@@ -169,7 +171,7 @@ mod tests {
 
     use zcash_client_backend::{
         address::Address,
-        data_api::{scanning::ScanPriority, AccountId},
+        data_api::scanning::ScanPriority,
         encoding::{encode_extended_full_viewing_key, encode_payment_address},
         keys::{sapling, UnifiedFullViewingKey, UnifiedSpendingKey},
     };
@@ -185,7 +187,7 @@ mod tests {
         testing::TestBuilder, wallet::scanning::priority_code, WalletDb, DEFAULT_UA_REQUEST,
     };
 
-    use super::init_wallet_db;
+    use super::{init_wallet_db, AccountId};
 
     #[cfg(feature = "transparent-inputs")]
     use {
diff --git a/zcash_client_sqlite/src/wallet/init/migrations.rs b/zcash_client_sqlite/src/wallet/init/migrations.rs
index 1285fffa9c..e044f0bb73 100644
--- a/zcash_client_sqlite/src/wallet/init/migrations.rs
+++ b/zcash_client_sqlite/src/wallet/init/migrations.rs
@@ -60,9 +60,9 @@ pub(super) fn all_migrations<P: consensus::Parameters + 'static>(
             params: params.clone(),
             seed,
         }),
-        Box::new(full_account_ids::Migration) {
+        Box::new(full_account_ids::Migration {
             seed,
-        },
+        }),
         Box::new(addresses_table::Migration {
             params: params.clone(),
         }),
diff --git a/zcash_client_sqlite/src/wallet/init/migrations/full_account_ids.rs b/zcash_client_sqlite/src/wallet/init/migrations/full_account_ids.rs
index b20529e7c7..6548821e3e 100644
--- a/zcash_client_sqlite/src/wallet/init/migrations/full_account_ids.rs
+++ b/zcash_client_sqlite/src/wallet/init/migrations/full_account_ids.rs
@@ -1,11 +1,12 @@
+use std::collections::HashSet;
+
 use rusqlite::{params, Transaction};
 use schemer_rusqlite::RusqliteMigration;
+use secrecy::SecretVec;
+use uuid::Uuid;
 use zcash_client_backend::data_api::HDSeedFingerprint;
 
-use crate::{
-    wallet::{init::WalletMigrationError, insert_address},
-    UA_TRANSPARENT,
-};
+use crate::wallet::init::WalletMigrationError;
 
 use super::ufvk_support;
 
diff --git a/zcash_client_sqlite/src/wallet/sapling.rs b/zcash_client_sqlite/src/wallet/sapling.rs
index 81c77e7752..cb9b12316b 100644
--- a/zcash_client_sqlite/src/wallet/sapling.rs
+++ b/zcash_client_sqlite/src/wallet/sapling.rs
@@ -17,7 +17,6 @@ use zcash_primitives::{
 };
 
 use zcash_client_backend::{
-    data_api::AccountId,
     keys::UnifiedFullViewingKey,
     wallet::{Note, ReceivedNote, WalletSaplingOutput},
     DecryptedOutput, TransferType,
@@ -27,6 +26,9 @@ use crate::{error::SqliteClientError, ReceivedNoteId};
 
 use super::{memo_repr, parse_scope, scope_code, wallet_birthday};
 
+type AccountPK = u32;
+type AccountId = zcash_client_backend::data_api::AccountId<AccountPK>;
+
 /// This trait provides a generalization over shielded output representations.
 pub(crate) trait ReceivedSaplingOutput {
     fn index(&self) -> usize;
@@ -39,7 +41,7 @@ pub(crate) trait ReceivedSaplingOutput {
     fn recipient_key_scope(&self) -> Scope;
 }
 
-impl ReceivedSaplingOutput for WalletSaplingOutput<sapling::Nullifier, Scope> {
+impl ReceivedSaplingOutput for WalletSaplingOutput<sapling::Nullifier, Scope, AccountPK> {
     fn index(&self) -> usize {
         self.index()
     }
@@ -67,7 +69,7 @@ impl ReceivedSaplingOutput for WalletSaplingOutput<sapling::Nullifier, Scope> {
     }
 }
 
-impl ReceivedSaplingOutput for DecryptedOutput<sapling::Note> {
+impl ReceivedSaplingOutput for DecryptedOutput<sapling::Note, AccountPK> {
     fn index(&self) -> usize {
         self.index
     }